-
How to create multiple spans and identify as 1 trace in jaeger?
Hello all, I'm trying to implement multiple spans and those spans should be identified as 1 trace in jaeger. (As shown in this video: https://www.youtube.com/watch?v=0uwy26zPc-o&t=1118s at 24:12 timing he shows the same concept.) I'm using java to implement. Can someone provide some ideas, tips and tricks, which could be a…
-
Two or more consumers for different topics
Here in this question, I managed to solve the queue issue: Two or more consumers for different queues Now, the following question remains: In the same application, I need to process non-persistent messages, which are sent to different topics and have different formats: 1) update-certificate; 2) update-credentials; In this…
-
Two or more consumers for different queues
In this example, I see only one consumer, in one subscription like here: https://github.com/SolaceSamples/solace-samples-java-jcsmp/blob/master/src/main/java/com/solace/samples/jcsmp/HelloWorld.java How should I create one consumer/listener for different queues? For instance, one consumer for certificateUpdate and another…
-
Consume a persistent Message from Queue or Subscription
After some studies, and proof of concept, I have a question about the consuming side, since the producer side is very clear to me. Let's say I need to save files using Solace Message Broker, so I have the following configuration for producer, topic, and queue: The producer sends a message with the Topic…
-
How to connect XASession of Solace JCSMP API with Weblogic Database XAConnection?
Hi team, I am looking for a way to connect solace XASession with database XA connection (my datasource is on weblogic server) so that if the query execution fails, solace transaction should rollback when db transaction.rollback is called; and same with commit statement. Or vice-versa - if solace transaction is rolled back,…
-
Retry mechanism with delay
We are adapting our services to use Solace, and one of our applications uses a retry mechanism with delay from RabbitMQ in which an error message would be sent to a DLQ, which had a TTL configuration and, after the TTL expiration, it would be sent back to the initial queue. Beyond that, the message had a specific header…
-
DMQ Eligible flag in Java different libraries
After some tests using JCSMP API, I assumed it is necessary to set this flag on the producer side to make the Dead Message Queue features working. Now, I am testing my new applications that use the Spring Cloud Stream with the Solace PubSub+ Binder and just see this parameter on the consumer side (Is that right?), which…
-
How to use Kerberos with Java RTO API?
With Java RTO API, I can set AUTHENTICATION_SCHEME to GSS_KRB. But other than that, there is no document on how I can specify other Kerberos options and keytab file. How should I do it? I really don't want to use RTO but it is the only Java API supporting both PubSub+ Cache and topic dispatching. Thank you very much.
-
Send a message to the Queue instead the Topic
After hours of studying in Solace Documentation, Youtube Channel and etc, I believe I've ended up with some points to check with you: Although we have some samples of sending a message to a queue, the best practice is to send a message to a topic. As I could see in the Spring Cloud Streams samples, this is the only way to…
-
Spring Boot XA Transaction Autoconfiguration?
Hello, I am working on a Spring Boot Java project where we are trying to incorporate XA transactions using the Atomikos implementation of JTA. However, we are struggling to see how to easily create the XAConnectionFactory. There does not seem to be any way to autoconfigure the creation of this bean and we are having to…
-
StreamBridge creating consumer and it's subscription
I have created a Spring cloud stream application that publishes messages to Solace. The publish message is triggered by an external event. I am using StreamBridge to achieve this functionality of publishing messages. My application.properties look like this Problem: when the application starts it creates a consumer queue…
-
PubSub+ Messaging API for Java releases
The following API has been released and available for download: * PubSub+ Messaging API for Java 1.0.0 Release Summary This is the initial release of the PubSub+ Messaging API for Java. Solace created this API to modernize our JCSMP API. This is a separate standalone API which provides modern interfaces, patterns and…
-
Non Exclusive Queue Behavior using MQTT
Hi, we have multiple consumers connected to a durable non-exclusive queue and when we send a message to the queue , only one of the consumers gets the message. Can it be possible to achieve the same behavior using MQTT / java-paho-mqtt ?
-
Library to Unsubscribe Topic from Queue
Hi Community, I am exploring Solace and its Use Cases. Using Solace Java API Library we can create a Queue and subscribe a Topic to the Queue. Using SEMP Java Client Library we can Create and Delete a Queue. Using SEMP REST API we can create and delete Queue , subscribe a Topic to Queue and can also unsubscribe a Topic…
-
Persistent receiver with subscription-specific listeners
Hi, Is it possible to have multiple topic-specific receivers and handlers to consume messages from a queue? Like: var receiver1 = messagingService.createPersistentMessageReceiverBuilder() .withMessageAutoAcknowledgement() .withSubscriptions(topicSet1) .build(queue) .start(); receiver1.receiveAsync((message) -> { //...…
-
Integrating the Solace Kafka Sink Connector with Confluent Schema Registry
Avro is a common message format used for Kafka records. Large Kafka implementations leveraging Avro often use the Confluent Schema Registry to ensure uniform record schemas across publishers and subscribers. When using the Solace PubSub+ Kafka Connectors to publish Kafka records as Solace PubSub+ events, it may be…
-
Batch processing with Spring Cloud Stream
Hi Solace Community, It's me again. So we moved from RabbitMQ to Solace and identified that Solace does not support batch mode. See: https://solace.community/discussion/811/spring-cloud-stream-batch-mode So we started to implement a manual Acknowledgement function to accomplish something similar. But we are stuck in one…
-
Clone Message in Java ? (for DMQ move to Main Queue)
I have a problem with functionality which is not implemented in all offered programming languages. The use case i work on is a utility to move messages from DMQ back to main queue to re-publish the messages). The problem is that there is a flag DMQ eligible…
-
Early Access Now Available for the New Java Messaging API!
🚀 I'm excited to announce that Early Access is now available for our new PubSub+ Messaging API for Java! Java as a language, and how developers use it, has evolved quite a bit over the past 15 years; and while JCSMP (our current Java API) has treated us well it is our oldest API and it is definitely time for a new, modern…
-
Integration Testing with Solace
All, I have a java based spring cloud stream application that publishes messages to solace topics based on an internal trigger. I am using StreamBridge to publish messages. I want to write integration test cases for it for which I need to bring up a solace server. Any idea on the best ways to do it? Thanks in advance!
-
New Tutorial Available - Spring Cloud Streams
A new tutorial has been posted to the Solace Samples pages! Be sure to check it out. https://tutorials.solace.dev/spring/spring-cloud-stream/
-
About changing sol-jms version in solace-jms-spring-boot-starter 4.1.0
Hello, Due to some reasons, I need to use sol-jms 10.11. However, I want to use solace-jms-spring-boot-starter for my project but the latest version of the starter (4.1.0) is using sol-jms 10.8.1. I want to change the sol-jms version by: <dependency> <groupId>com.solace.spring.boot</groupId>…
-
Early Access is Now Available for the New Java API 🎉
Early Access is Now Available for the brand new "PubSub+ Messaging API for Java" 🎉 Solace Community members can find out more about the API in the "Early Access API" category here: https://solace.community/discussion/643/early-access-now-available-for-the-new-java-messaging-api
-
Create a Spring Cloud Stream Microservice in 5 minutes
Hope everyone is having a great week. I wanted to share my newest blog and video where I show how simple it can be to get started with Spring Cloud Stream using start.spring.io & of course a Solace PubSub+ Event broker. If you've never done it, you should give it a shot! It only takes 5 minutes :) Blog is here. And Video…
-
Extract Topic Name from Java Beam pipeline
I am using java beam pipeline and want to extract topic name from solace. But I am not getting any such function or anything to do the same.
-
Consuming messages from solace queue but not writing to GCS
I am working on java pipeline code to consume messages from solace queue and write it to GCS. With the same code I was able to do the same but from past 3 days with the same code I am only able to consume messages but it is not writing to GCS. Today I ran the code again so it is not consuming messages from solace and…
-
How to publish and consume an attachment(.txt) file along with each message in queue?
Is there a way to publish a message and an attachment(.txt) file to a queue? Can this message and the attached file be consumed using java interface?
-
📣 JAVA Folks! New upcoming PubSub+ Messaging API for Java 📣
I wanted to start this discussion to see who is using the Java implementation of the Solace Messaging Protocol API? Good news is we are releasing a Brand New Java API: "PubSub+ Messaging API for Java" so stay tuned and let me know if you want to be one of the first to try out this API and give us feedback. Early Access of…
-
Quarkus native and solace client issue
Hello, I'm developing an application with Quarkus and Solace. Quarkus allows you to compile java to a native application. Compilation is fine, but at runtime I have this issue: 2020-11-13 12:49:18,462 ERROR [io.qua.run.Application] (main) Failed to start application (with profile dev): java.io.FileNotFoundException:…
