-
can commands be issued into Solace PubSub+?
I'm new to Solace PubSub. I'm wondering if it's possible to issue commands into PubSub broker so it can get picked up somewhere else? Or, are only events issued through PubSub broker? Thank you for your time.
-
Solace - Spring cloud stream binder.
I found strange issue with my app. Application should have the bind count to 20 (4 Instance, Each with default 5 concurrency) but it went down to 2, the consumers for that queue stopped consuming and message started to spool. When i added another instance of the service the bind count went upto 7 and messages were consumed…
-
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…
-
Issue in posting xml message to queue via REST messaging
Hi i am trying to post an xml message via postman to queue and I use content type as application/ xml . The data is not coming as an xml . Should I add any other header
-
Client latency/response time
Hi We are using Solace to push market data to client applications via direct messaging. I have noticed that some clients struggle to consume data at the same rate due to connectivity issues. When network dips occur or when you reach a wifi 'dead zone' some client fall behind on market data. In order to alleviate the load,…
-
Spring cloud stream concurrency
Hi there I'm trying to configure more than one Consumer Thread for my functional consumer, the yaml file looks like this: cloud: stream: function: definition: bookIn bindings: bookIn-in-0: destination: BOOK group: BOOK_CONSUMER consumer: concurrency: 13 # has no effect_ The value is actually taken over into 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…
-
How to set DMQ Eligible flag in Spring Boot
Hi there, i am using solace-jms-spring-boot-starter and jmstemplate in spring boot to send messages to queue. How can i set the DMQ Eligible flag over jmstemplate? Currently all my messages have the status DMQ Eligible NO. public void sendEvent() throws Exception { String msg = "Hello World " + System.currentTimeMillis();…
-
Springboot Solace JMS Autoconfig with Client Authentication
I am using SpringBoot Solace JMS AutoConfig to listen and produce message for solace queue. I am currently using Basic authentication. Now, I am trying to use Client Authentication using truststore and key store. How do I connect to Solace using JMS AutoConfig?
-
Solace and Boomi - Acknowledgement process
Hi, I need some guidance and help regarding acknowledgement process of Solace. 1.I have Boomi process which gets input (payload) from external system and sending xml to Solace topic.Here how to acknowledge the source system the message is received in Solace in success. What settings are to be done in Solace Pubsub +…
-
Unable to connect to existing solace queue instead trying to creating a new durable queue and fails
Asking help from this community after coming through several articles and sites. Didn't find solution I want to connect and use manually created queue, but it is not working. refer the below properties and error i am getting. Any recommendations? Details Spring Boot Applicaiton created using start.spring.ip with the…
-
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…
-
What is the difference between all the different Queues?
As I was trying out Solace PubSub+ with java implementation I tried to use Persistent messages as our previous eventing system used a similar concept. As I was exploring the concept of Queues showed up and I noticed there were many different kinds. The first part of this question is what is the difference between…
-
[Explainer Video] How PubSub+ Enables an Event Mesh
Watch this short explainer video to understand how PubSub+ Platform enables an event mesh where brokers can be deployed on-prem, public clouds, and remote locations. https://solace.com/resources/videos/how-pubsub-enables-an-event-mesh
-
Outbox Pattern Alternative using PubSub+ Transactions?
I need to sync the publishing of events with MySQL database transaction commits, and was planning on using the Transactional Outbox Pattern for this (https://microservices.io/patterns/data/transactional-outbox.html). However, I was wondering if PubSub+ transactions can be leveraged for this, maybe with two-phased commit?…
-
Limit Max Connection per Consumer (not client)
Problem: I have a micro services which offers some REST endpoints and as well runs some Solace Event listeners. The problem is now that the service scales up and down based on incoming requests and so as well the listeners are increasing with the scale. Any listener for sure blocks then a connections from solace although…
-
Looking to get some more clarity on the solace api for Solace PubSub+
Hi Solace community, I am currently looking into Solace PubSub+ tutorial and documentation and I noticed that there was ~4 different java implementations. I was wondering what is the main difference of each implementation is all these different option available for convenience or is there a fundamental difference in what…
-
🎉 YOU'RE INVITED: Come to a free virtual live Solace Dev Jam with Aaron! 🙌🏼
MAIN EVENT PAGE: https://solace.community/events/63-youre-invited-come-to-a-free-virtual-live-solace-dev-jam-with-aaron-%F0%9F%8F%BC Check the Events page for the timing! I'm cross-posting. Hi everyone! We're trying something new here. I've been doing workshops with customers and prospects for years, in-person and virtual…
-
Configure a non Transacted Router in JMS Tool Box
Hello, I'm trying to get access to a queue through JmsTool Box, but I'm getting the following error : com.solacesystems.jcsmp.InvalidOperationException: Capability Mismatch: Router does not support transacted sessions. Capability Mismatch: Router does not support transacted sessions. The transacted mode is explicitly…
-
[Demo] PubSub+ Distributed Tracing
The new distributed tracing functionality will let you observe events on a step-by-step basis so you can easily troubleshoot delivery and performance problems. If you are interested in participating in the early access, let @rtomkins know. Watch the demo
-
Message type for Object type (JAVA)
Hello, First things first, I'm a complete newb regarding Solace PubSub+. I'm trying to build a library to be used as a dependency that will deal with all the solace communication. In my case, I want the library to be abstract in a way where it does not care about what kind of information it is dealing with. My problem is…
-
Subscribe to direct messages with RequestConfirm and correlationKey (.NET)
Hi, I'm using .NET. I would like to subscribe to direct messages. I have set session property SubscribeBlocking to false. I plan to use TaskCompletionSource as correlationKey and complete it when handling SubscriptionOk or SubscriptionError. Unfortunately I can't find suitable overload of ISession.Subscribe. There are 3…
-
JCSMP get numbers of messages in QUEUE
Hi, is it possible to get actual number of messages in a queue with JCSMP API ? I want to monitor that number each 5 sec.
-
How long does temporary queue last after client disconnects?
Hi. I would like to use temporary queues to make a client more robust so even if the client disconnects for a short period of time it won't lose any messages thanks to the queue. It's also desirable that temporary queues are destroyed if the client doesn't reconnect so too old messages don't waste space of the broker.…
-
SEMP API to delete the messages from the queue?
Hi Team, Is there any way or SEMP API available to delete the messages from a queue? Thanks Tejas
-
Why is the flow in the HandleMessageEvent sometimes null?
Hi, we implemented a Solace consumer using the .NET API following the guidelines (https://tutorials.solace.dev/dotnet/persistence-with-queues/). When runnung some tests we figured that sometimes messages were not properly acknowledged and removed from the queue. When debugging the HandleMessageEvent we found that…
-
Sending json message using Python to queue using Kerberos authentication.
Does python api supports solace Kerberos authentication?. If so can any one share sample code? If not what are other ways to use Kerberos authentication for sending json message.
-
[That Tech Show Podcast] The Magic behind Event-Driven Architecture with Jamil Ahmed
Listen to the podcast where Jamil Ahmed, Distinguished Engineer from Solace, shared with That Tech Show hosts Samuel Gregory and Chris Addams the "magic" behind Event-Driven Architecture (EDA). Podcast link: https://www.linkedin.com/posts/jamilahmed_tech-podcast-eventdrivenarchitecture-activity-6943149842852397056-TiLP
-
How does the sslvch option of SDKPerf work
In the newer version of SDKPerf, such as sdkperf-jcsmp-8.4.5.19, sdkperf-jms-8.4.6.5. There is an option "sslvch", the description is "Enable validation of certificate hostname". How does the validation work? and what is the expected out put when this option is applied? I tried different combinations, but didn't see any…
-
.Net integration using .pem certificate
Hello, I'm looking for some help on how to import .pem certificate and use it .Net code. Any help or sample implementation for reference will be appreciated.
