-
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…
-
Semantic conventions
Are there any semantic conventions recommendations for open telemetry attributes for solace such the recommendations for kafka. https://github.com/open-telemetry/semantic-conventions/blob/main/specification/messaging/kafka.md ?
-
Spring Cloud Stream - Confirming publication and Acknowledging Receipt
Hi I read the following as well as some of the guides which talks about publishing and the dispatch being async. All the examples refer to using a StreamBridge however, the same case occurs when an application is a 'processor', in which case we can't use the CorrelationData approach as described. Please correct me if I am…
-
Does Solace spring cloud stream binder support messageSelector?
im trying to find a way to configure messageSelector for my SCS queue consumer to filter messgaes coming to my queue based on a specific header value (ex: eventName = 'productCreated'). please let me know if the current version of the Solace SCS binder supports it?. if yes, do share a sample. if no, any plans to support in…
-
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.
-
Clarification on queue use-case
I have a publisher posting messages to various topics. I have no idea what applications are going to read from these topics. These are for example sales orders, so durable messages. I had the following in mind: create a queue and let subscribers read from that. However, to my understanding, the message queue can only be…
-
configuring solace - how to pass via cliscripts the server certificate password
Hello, I am trying to automate the complete configuration of a solace server (running in a docker env, but I dont think it matters here). Via the use of cliscript (cli -s cliscript.cli), I can configure many element like passing the CA certificate, ect, but I cannot automate the passing of the server certificate password.…
-
Message redelivery on Exception
Hi, I'm evaluating a move to Solace by playing with a PubSub+ Cloud free instance. I'm not sure to understand the message redelivery policy. My implementation is based on spring-jms backed by qpid amqp. I was expecting that an exception thrown from a @JmsListener annotated method would reject the message which then would…
-
Solace CLI Commands in PubSub+ Cloud / Software Event Broker / Appliance
Are there any differences in terms of Solace CLI commands among PubSub+ Cloud / Software Event Broker / Appliance? I cannot find some commands mentioned in the help pages when I connect to CLI in PubSub+ Cloud? Thank you
-
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…
-
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 ?
-
Possible to export message payload in queue level
Hi team, I have one query, recently we are facing issue client disconnected in one queue and message are spooled in queue around 1 lak. Is there any possibility to export the message payload, if yes please let me know the procress.
-
C#.Net and the connection factory
Good day, I am trying to develop a service that will connect to an entity using the JMS functionality. The setup information provided by the vendor has a connection factory and jndi factory but I can't seem to find any reference to this in the tutorials for C#. I have found these references in the Java code bases. Is there…
-
how to increase link quota size
Hi Team, For clusters what are the steps to increase link quota size
-
Can we degrade solace version from 9.9 to solace version 9.6
Hi Team, Can we degrade solace version from 9.9 to solace version 9.6 Any impact?
-
Anyone using Quarkus or Micronaut with Solace Event Brokers?
Hey all, I've been getting a few questions lately around using Quarkus or Micronaut with Solace messaging APIs. I'll admit I'm not an expert in either of those, is anyone using them? If so, have you been successful? Any chance you can share a project? @gaetancollaud - I saw you posted a while back about Quarkus, did you…
-
Timestamp for oldest message on a queue
Is there some simple way to get the timestamp of the oldest message on given queue with semp? For example is the list of message in getMsgVpnQueueMsgs ordered (see below)? Or can it be? Obivously the broker knows what first first message to be poped on a given queues is.
-
Solace Jav RTO Max Send Buff and Receive Buff
Hi, I am using Java RTO and I am not really clear with Max Receive Buffer Size and Max Send Buffer Size. Say if my Send Buffer size is 1024 bytes, does it mean Solace API waits and collates messages upto 1024 bytes and sends them together ? Similar question of the reveive Buffer Size.
-
application going on non responsive mode after Consumers window size 0
application going non responsive mode after Consumers window size 0 under the Queue configuration I am not sure why window size is getting 0 . could you please help anyone , when the window size will be 0 and how to resume application after window size 0 ?
-
Remote Bridge Limitation
Hi Everyone, Is there any limitation to add the remote bridges to the uni-directional bridges. I can able to add only 4 remote bridges after that getting the error "Quota Exhausted". Thanks in advance !!
-
how to configure to enable MQTT QoS1exchange in Solace
HI Dears, In this document https://docs.solace.com/API/MQTT/Using-MQTT.htm, we can enable QoS1-At least once delivery for MQTT， could you help to provide the details guideline how to configure QoS1 in solace for MQTT client? Thanks Lei
-
Java RTO Context Handle Busy Spin
Hi, I have allocated core while initializing Context Handle but it doesn't keep the core busy and due to this first message is always has high end to end latency. How can I keep Context Handle on busy spin ? My Java RTO is version 7 and Java 11.
-
Message Eliding maximum topics
Hi! I would like to understand a bit more on one of the settings Maximum Eliding Topics Per Client Connection. If I set this as 1 and subscribe to a hierarchy of a/b/c/> containing two topics a/b/c/d and a/b/c/e , will both my topics be tracked? Or will solace choose one of the topics randomly? In short, is this property…
-
Help with setting up appropriate endpoints.
Hi, I have a pretty standard use case, but am struggling to work out a basic architecture, perhaps you can help? We have a producer which would publish prices at random on a topic. We have a number of consumers who all need to consume these prices. When these consumers start up they need to obtain the last published price…
-
StreamBridge null pointer with Spring 3
I try to get "spring-cloud-starter-stream-solace" version 3.0.0 with spring 3.1.0 running. But every time i use the "StreamBridge" i get this error message: 2023-06-01T14:38:25.602+0200 ERROR Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed:…
-
How to disable the automatic queue creation with amqp qpid jms client
Hello everyone, I am following the tutorial provided here: GitHub - SolaceSamples/solace-samples-amqp-qpid-jms1: Getting Started tutorials for using Apache Qpid JMS 1.1 over AMQP 1.0 with Solace Message Routers. I want to create a consumer on my queue which receives messages. This does work, however everytime the client…
-
Rewrite URL Path - RDP Rest Consumer
Is it possible to rewrite the URLs before sending the request to the Rest Consumer using solace RDP? For example: https://192.168.5.111:9443/api/deleteResult -> http://192.168.7.111:7001/test/deleteResult?
-
how to add topic subscription to durable topic endpoint in solace via CLI
Hi All, how to add topic subscription to durable topic endpoint in solace via CLI/soladmin/WebGUI Please suggest!!
-
503: Too Many Connections For Client-Username
Hi All, Getting error as : JNDI lookup failed - 503: Too Many Connections For Client-Username Configured Max Connections Per Username but no luck, please suggest way forward.
