-
Delay Delivery Queue Property with New Java API
Hello, I am creating a Solace consumer using the new Java API with the "create resource" strategy. My application will create a queue if it does not already exist. I would like to add the capability in my code to set delayed delivery, which we are currently configuring through the Solace dashboard/CLI. Is there a way to…
-
Solace fail-over test - affected consuming of event
Hi, While doing Solace fail-over test, once the test was initiated, the SolaceHealthIndicator Status change in following chronological order : DOWN -> RECONNECTING -> UP We didn't observed and pod restart. However, the consumer was in stale state, where no events were being consumed. Note that the event consumer health was…
-
Spring cloud stream solace binder StreamBridge.send() unexpected error
Hi Solace team, we are using Spring Cloud Stream Solace in our Spring Boot project, when we try to send messages simultaneously from 5 different threads by using `StreamBridge.send()` the underlying implementation "randomly" throws `org.springframework.messaging.MessagingException`, by randomly I mean it doesn't matter if…
-
Spring JMSListener fails all the messages in the queue
I have a queue endpoint that's configured with non-exclusive access redelivery enabled with the default redelivery delays delivery count of 10 a dmq queue name non partitioned and pretty much everything else is the default values. I also have a springboot message listeners that has a concurrency of 1 is auto acknowledge…
-
Opentelemetry support New Java API
Hi Team, I am building an application with new Java API. And I have a use case to integrate with open telemetry for distributed tracing. I guess 1.4.0 version is not supporting open telemetry. When can we expect the support? or is there any way that we can achieve this ?
-
solace starter / spring boot 3.2.0 compatibility.
Hi, Solace starter is behind in terms of spring boot versions. I'm trying to upgrade to spring boot 3.2.0 but it's causing issues with the existing latest solace spring boot starter 2.0.0 (issue detail further below). It works fine with spring boot 3.1.6 version. Are there any plans to upgrade the spring boot dependency…
-
How to consume messages synchronously from a solace "Queue" via Spring boot application?
Hi Team I am trying to develop an application where we connect to a Queue ( which is subscribing to multiple topics) and read message synchronously and make sure the next message is consumed only after current message is acknowledged. I tried reading resources provided by solace documentation and found snippet available…
-
in spring cloud stream 3.2.3, how to Manually Handle Null Payload manually
preSend or extending AbstractMessageHandler did not work, And @StreamListener annotation is deprecated How to handle it, without changing any versions
-
Spring publisher confirmation when channel is closed
Hi colleagues, We use spring-cloud-starter-stream-solace 3.5.0 and we have a question regarding this documentation https://github.com/SolaceProducts/solace-spring- cloud/tree/master/solace-spring-cloud-starters/solace-spring-cloud-stream-starter#publisher-confirmations. We are running a test scenario in which an…
-
Reprocessing Messages
I have a scenario similar to the one mentioned in this post How can I get it to work in JCSMP with spring boot?
-
How to enable TLS connection in spring boot?
Hello everyone, I have successfully integrated queue communication in solace with spring boot but I'm facing an issue. I want to make it such that any client without a valid certificate (jks) is not allowed to connect even if the credentials are valid. It seems that the default settings allow anyone with credentials to…
-
Spring Cloud Stream Batch Consumer and Batch Publisher using Function
Consumer spring.cloud.stream.bindings.receiveMessage-in-0.consumer.batch-mode=true spring.cloud.stream.solace.bindings.receiveMessage-in-0.consumer.batchMaxSize=255 spring.cloud.stream.solace.bindings.receiveMessage-in-0.consumer.batchTimeout=500 ### Publish messages to Topic…
-
Spring Cloud Stream | Batch | TPS | Tuning
In our micro service, we are using solace binder with SCS, during non-functional testing we found some differences in performance, Could you please help to understand. service - Processor is used. The TPS is approx 200 TPS. Function<Message<List<String>>, Collection<Message<SafeStoreObject>>> receiveMessage() The…
-
Spring Cloud Stream | Solace connections
Hi All, I am running a microservice with Spring cloud stream The batch mode is true and batch size is 255. So does the service opens 255 connections to read the msg ? as i am seeing the window size is 255. which controls this window size of the solace queue.
-
Effortless Request-Reply Functionality for Spring Cloud Stream Binders
Simplify Request-Reply Communication with spring-boot-starter-request-reply Hello, Spring Boot developers and integration enthusiasts! We're pleased to announce the launch of the spring-boot-starter-request-reply, a new addition to the Spring Boot ecosystem. This starter aims to enhance communication capabilities in Spring…
-
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…
-
Spring Cloud Stream Solace - Manual Acknowledgement
The batch mode is working fine as i am able to receive the msgs as batch and publish as batch. Now, i am trying to manually acknowledge the messages. If no exception, update the database with success and then accept the message. Else, update the DB with error and then requeue the message. Function<Message<List<?>>,…
-
Spring Cloud Stream Data Type in Function
Function<Message<?>, Message<?>> The function takes the input paylaod as bytes even when datatype is mentioned. The auto conversion from json to pojo is not happening. Any suggestion? For example, Message<ClassName> when i directly use it, i am getting Class class exception ClassName a = message.getPayload(). Works as…
-
Failed to consume a message from destination
I have a queue A which has many topic subscriptions. We run our microservice using Spring cloud stream stack. When queue A receives messages from different topics and processing them and all of a sudden, we see below exception stacktrace is continuously printing in the logs. I am not sure about the reason, while it is…
-
Spring Cloud Stream Batch Consumer and Batch Producer
Batch mode is true and batch size is 10. Still when we run the application with volumes of data, the batch size grows upto 75. Any suggestions on the below properties? Properties: spring.cloud.stream.bindings.receiveMessage-in-0.consumer.batch-mode=true…
-
Spring cloud Stream Solace Unit Test
Solace Spring Cloud BOM 2.4.0 Solace Spring Cloud Stream Starter 3.4.0 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream</artifactId> <type>test-jar</type> <scope>test</scope> <classifier>test-binder</classifier> </dependency> <!--…
-
JMS Queue Browsing (Received incoming message with no active flow)
I am developing a Spring Boot Application (version 2.7.5). Currently, I'm trying to create a queue broswer using the following code: public int getMessageCount() { return jmsTemplate.browse(fromQueueName, new BrowserCallback<Integer>() { @Override public Integer doInJms(Session s, QueueBrowser qb) throws JMSException {…
-
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…
