Java

Spring cloud stream Solace binder prevents application from running when Solace is down
Hello everyone, I am currently working on an application that consumes messages from Solace and serves users with HTTP endpoints. However, when Solace is down, the Solace binder prevents the application from running until Solace is reachable again. This behavior is problematic for our business as we want to continue…
JMS 2.0 support on sol-jms
Spring Boot 3+ is using JMS 2.0 and packages jakarta.jms.* instead of javax.jms.* (check for example: Thus solace spring boot starters cannot be used with spring boot 3 applications. https://github.com/SolaceProducts/solace-spring-boot/pull/60 Are there any plans to mitigate this obstacle ? Or any way to fix it ?
Solace Client metrics to scaling my application
Hello guys, I'm migrating from RabbitMQ to Solace, there's a feature important in my spring boot applications with the rabbitmq client about metrics. We are using the metric `rabbitmq.consumed` to find the rate of consumed messages per second and scaling horizontally after a certain threshold. I'm able to get this metric…
Unable to connect with solace using amqps protocols with OAuth
String solaceHost = "amqps://<host>:<port>?amqp.saslMechanisms=XOAUTH2"; String solaceUsername = Username String solacePassword = access_token Error : Authentication has not completed yet. Please find attached logs
Reprocess Messages from DMQ to Queue of the solace
I am able to reprocess messages from Solace DMQ to queue using the browser in JCMP solace package. But now I am facing an issue to process a particular message based on the message id or to process few messages that is there in between a date range. Please help me to find out which package or module I can use to check the…
Not able to update JWT using updateProperties()
Hi Solace Community, I am using the Java Api version 1.1 Currently I am experiencing a problem that I am unable to resolve where calling the "updateProperty()" function for the messaging service isn't logging, returning feedback or actually changing the JWT token that I am sending. The JWT I am generating is successfully…
Integrating Spring Boot with the Solace PubSub+ Messaging API for Java
Hi Everybody, Happy new year and hope you have a wonderful 2023 ahead!! We do not yet have a Spring Boot Starter for the Solace PubSub+ Messaging API for Java and I've been getting some questions around how to use this API with Spring Boot so I created a new samples repository with code showing how to do so. The…
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…
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…
Error registering listner:Transactions not supported [condition = amqp:not-implemented]
Hello, I am trying to register listeners dynamically to the queues whose names can be fetched at runtime. I am using the JmsListenerEndpointRegistrar from spring for dynamic listener registration. My application is started, and connection to solace broker gets established but the listener invocation fails with the…
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…
Consume from multiple queues in Spring Cloud Stream
Yesterday I got asked by a developer how she could have multiple functions in her Spring Cloud Stream microservice each consume from its' own queue. Luckily the framework makes this relatively simple to accomplish, but the devil is in the details as your configuration must match your code so I figured I'd share the steps…
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…
How to send NACK(Negative Acknowledgement) using java API
Hi Team, Need your help to find the solution. Current Implementation details, SolConnectionFactory connectionFactory = SolJmsUtility.createConnectionFactory(); --> for create connection factory using host , vpn,trust store,keystore with auth scheme AUTHENTICATION_SCHEME_CLIENT_CERTIFICATE this.connection =…

Java

All Time Leaders

This Week's Leaders

Java

Discussion List

All Time Leaders

This Week's Leaders