-
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.
-
When import the certificate getting error access denied
When i used the sanbox account certificate not got any error when we try to import the UAT certificate in our application getting access denied error when both certificate have same detail we used .pfx that extract from .cer file.
-
How to set up consumer in Azure Container Instances using python qpid proton
Hi all, I have been trying to deploy a consumer as an Azure Container Instance implemented in python, which uses qpid proton. When running the Docker image locally it works without any issue, however when deploying the image as an ACI, I obtain the following error: ```2022-06-03T16:05:19UTC ERROR: proton - Couldn't…
-
I want to add delay on consumption of messages. Delay will be dynamic in my application.
I want to add delay on consumption of messages. Delay will be dynamic in my application. Example: For Message A delay will be of 1 min and for Message B delay will be 2 min. I tried with below code of snippet but it's not working. TextMessage msg = JCSMPFactory.onlyInstance().createMessage(TextMessage.class);…
-
Found issue, Where messages were stuck in the queue, it wont accept and let consume from queue
The messages were stuck in the queue, we cant publish anything to it but the problem is the listener is not even consuming them to create space for new messages. Caused by: com.solacesystems.jcsmp.InvalidOperationException: Tried to perform operation on a closed XML message producer 2022-06-02T15:38:25.309-05:00…
-
CLIENT EGRESS MESSAGE DISCARD | Transmit Congestion
We use guaranteed messaging. How to interpret Client Egress Message discard due to Transmit Congestion ? Does these mean 3014 message got discarded ? If yes, Why the message should get discard in guaranteed messaging case ! Ideally it should spooled in Durable Queue. ****************************** Egress Discards…
-
Can we have application connect to multiple Data Centers to achieve active/active capability
We have a use case where we have 2 data centers with guaranteed messaging , currently we want HA hence both data centers are active all the time, so we have DC1.VPN1 with Q1 that is consumed by Client 1 DC2.VPN2 with Q2 that is consumed by Client 2 The publishing of events happen either in DC1.VPN1 or DC2.VPN2 based on…
-
Spring Cloud Stream solace error handling
In the codelabs example it suggests we shouldn't use global error handler as suggested by spring because binder will already be handling it. Is there a recommendation how you'd configure error handler channel for an application which uses a system property to determine the destination queue in order for the application to…
-
Queue and consumer number limit with solace docker image
Hello, We are using solace image tagged (public.int.repositories.cloud.sap/solace/solace-pubsub-standard:9.13.1.38) in our CI. As it uses more memory ,this instance is shared across all the PRs in CI. We are using the default VPN for connection settings. is there a limit of 1000 queues and 1000 consumers on the open-source…
-
how to stop message from being sent to next solace topic while going through chain of function?
how to stop message from being sent to next solace topic while going through chain of function? e.g. inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here message goes through inTechVal|inFuncVal|map|persist|report all of these functions but if i want to terminate and…
-
How To Create Docker Image For Go Client ?
Hi Team, Tried Creating the Docker image for Go client, but Facing the Below Error seems the Go package has issues, can someone help on this? # solace.dev/go/messaging/internal/impl/constants 53 /go/pkg/mod/solace.dev/go/messaging@v1.0.1/internal/impl/constants/default_properties.go:35:2: undefined:…
-
JCSMP Blocking Publisher Example: Timeout configurable
Hi Community, I have a question on the JCSMP BlockingSynchronousSendGuaranteed.java sample: What happens, if the broker doesn't respond with either an ACK or a NACK? Is this even possible or under which conditions could that occur? (I read something about disk full could be one potential situation.) Is there a timeout for…
-
How can i gurantee sequence of events to be consistent.
Lets assume i have 4 events Event A producing message to Queue AQ Event B producing message to Queue BQ Event C producing message to Queue CQ Event D producing message to Queue DQ Lets assume consumer named TestConsumer consumer consumes messages from all 4 queues. I want to make sure when solace emit these events it will…
-
Can we discard or reject message in solace streaming?
this is our declaration spring: cloud: function: definition: inTechVal|inFuncVal|map|persist|report stream: function: bindings: inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here solace streaming is sending message out to solace as per out mapping e.g. after…
-
Is it possible to have DMQ configured with a remote Queue using VPN Bridge/DMR
Hi, Is it possible to have a DMQ configured with a Queue that is not in the current VPN but in another remote VPN/Data Center ? This will help in handling cases when a Queue events/messages are not being processed due to inactive client in one VPN/Data center , so it can be sent to a DMQ in a different active VPN/data…
