-
Message Signing Questions
Are the message broker able to verify message signing ? For example, Client A signed the message and sent the message to message broker. Then, the message broker check the message and reject the message if the message contain incorrect message signature.
-
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…
-
Consume Solace message behind corporate proxy
Hi, We are consuming messages from Solace via VPN connection without any issue. Now we need to consume from Solace behind our corporate proxy. I found there is no interface provided in SolConnectionFactory for this, and it is not taking proxy settings from our environment variables also. Is there any way to setup Solace…
-
New blog post for Boomi developers | Tips and tricks for consuming persistent events💡
📣 Calling all Boomi Developers! Are you using the Solace PubSub+ Connector in Boomi? Have you wondered about the different modes of consuming events? Are you curious about dead-letter queues or last-value queues? Have you needed to co-ordinate state between different Processes/Atoms? ✅ If you've answered 'Yes' to any of…
-
Ensure only one publisher for a queue?
If I have a queue that has yet to be populated with messages, and I have multiple instances of a Spring application that have a method to publish messages to this queue upon starting, how can I ensure that only one of these applications will execute the publishing method in order to avoid duplication of messages published…
-
High disk usage
There was no consumer connection to the Queue, resulting in an increase in the current spooled messages. My question is, will the increase in current spooled messages also result in a corresponding increase in disk read usage? Someone please confirm? I have attached a graph for more details.
-
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…
-
null payload close the consumer flow receiver
Hi All, I am using cloud stream lib for message consuming from solace. If the inbound message has 'null' payload, then InboundXMLMessageListener.xmlMessageMapper.map(bytesXMLMessage) throws SolaceMessageConversionException. And as a result, it ends with "Closing flow receiver to destination ...". And no further messages…
-
Expose Solace Service to the Internet using Kong Ingress
I am using Solace PubSub+ standard, which is deployed using Helm Chart. All pods and services are up and running. I have exposed Solace service into the internet using Kong Ingress. Issue is I am able to expose using root path, I want to use custom path. Please help me with the configuration changes that are made.
-
Favourite Solace Swag
A bunch of people from the community have been getting some Solace Swag - what is your favourite?! Post it on this thread in the comments below and show us what you have. My favourite is the Solace Community shirt with the Solace mug
-
Connection to SAP S4 HANA Cloud
Hi, Is it possible to connect Solace PubSub+ to SAP S4 HANA cloud.If yes, could anyone help me on how to do that. Regards, Keerthana
-
OperationError: Cannot send message - no space in transport.
Hi guys We are building a browser based fx trading platform This platform is fully event driven & all communication goes via a solace software broker hosted in AWS. One capability that we have in place on the front end, is that when your connection drops (solace connection retries), we store/persist all telemetry data…
-
Message Delivery Count in New Java API
I am using New Java API for my implementation. I would like to have a configuration like spring cloud binder eg : maxdeliveryCountforQueue:<number> or One particular Event type max deliverycount. I can see queue we can configure max delivery count and broker is tracking that info. But If I am getting the information in…
-
Does Solace support any kind of Connector from/to MSMQ ?
We currently want to integrate a .net based solution and i wanted to know if any connectors exists from/to Solace from/to MSMQ ? Or is only option to use the .net API and receive messages to forward into MSMQ ? (message bridge)
-
How to set max-delivered-unacked-msgs-per-flow via JCSMP API
I see that .Net API has methods to set WindowSize and MaxUnackedMessages () But I do not see any such documentation for JCSMP API, can you please let me know how to set those? Regards, Karthik
-
TTLs & Message Processing
Dear Experts, I am trying to use JCSMP client and I have three questions w.r.t message processing at client side and TTL : I have realised that if a message expires just at the moment it is being listened to at the client side, the message would be processed by client and also re-delivered via DMQ (as I am listening to DMQ…
-
Support for Priority ?
We are currently looking into a multi tenant integration (up to 800 tenants). If we would create 1 queue per event type we would get 20+ Event Types * 800 Unit = 16000 Queues!!!! So alternative would be to have 1 queue per Unit but in this queue different message events will arrive and some are more important and some…
-
cache request on python
I use CachedMessageSubscriptionRequest.cached_first to call cache data but I got Fail on_completion CacheRequestOutcomeListenerHandler:CacheRequestOutcome.FAILED, cache_request_id:3 exception:Unable to send cache request. Caller Description: On cache request send. Error Info Sub code: [1]. Error: [Only…
-
Cache request on python
I found that solace PubSub+ 1.6.0 support cache But I follow this step to do cache request I can not receive the cache message from direct_receiver.receive_async(MessageHandlerExample()) but I can use DirectMessageReceiver.add_subscription to get message(CacheStatus.LIVE). and I also develope C# code it allowed call…
-
what changes are required on Solace VPN to connect to Kafka Connector.
From a solace admins end what are changes i need to make to my VPN, so the Kafka connectors can connect easily.
-
New blog post for developers | Introducing Architecture Diagram Icons
A big part of our developer relations team's mission in life is making life easier for developers of event-driven systems, so I'm pleased to introduce a new set of icons that I hope will make it easier for architects, developers and dreamers looking to communicate and collaborate on their ideas for building event-driven…
-
Introducing Solace & EDA Icons for Architecture Diagrams
Hi Folks! 📣 I'm excited to share that we now have Solace & EDA Icons available for everyone in the Solace Community to use when creating architecture diagrams, specifically those built with the products of Solace PubSub+ Platform, including our event broker, event platform and wide range of APIs and connectors. ⭐️ Here are…
-
Which Java client API to use ?
So I am a bit confused on which Java client API to use for connecting to a solace appliance from an application. My understanding is that we have the option of using JCSMP , RTO , JMS , Spring JMS vs Spring JCSMP ? Could some one please summarize at a high level what are the pros and cons of each approach in terms of…
-
Defragmentation Failing: Unmovable Local Transaction
I'm having trouble running defragmentation of a broker's message spool - which is currently at 90% and using up all the disk space. Each time I run defragmentation it completes about 5% until it exits with the same Exit Condition: ``` Last Result: Completed On: Oct 30 2023 07:29:21 UTC Completion %: 5% Exit Condition:…
-
Should the FlowReceiver be closed before recreating a new FlowReceiver?
I am following along with this solace tutorial. I am now testing and handling this portion of the tutorial where I handle REPLAY_START_TIME_NOT_AVAILABLE: . I have added a System.out.println(consumer.isClosed()); before I recreate a new FlowReceiver to replay from the beginning. This is printing out false.…
-
Can Solace event listening by a client with multiple user accounts?
I am face a problem, as some of the clients in solace is not maintaining by me, I would like to define multiple user account for the same client to prevent if any account expired on their side, is it possible?
-
Is there a difference for Solace CLI Commands in PubSub+ Cloud / Software Event Broker / Appliance
Is there a 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
-
How to keep the queue consumer flow open?
Hi everyone, I have actually a bunch of questions, hopefully it's okay to ask here :) How to keep the queue consumer flow open? Example Consumer provided here (https://tutorials.solace.dev/dotnet/persistence-with-queues/) gets messages only currently on the queue and closes immediately after that. How to keep the flow open…
-
Sending large amount of guaranteed messages with nodejs
Hi, we want to send a large amount of guaranteed messages with nodejs. Our code is similar to https://github.com/SolaceSamples/solace-samples-nodejs/blob/master/src/basic-samples/ConfirmedPublish.js but without limited number of messages (we do not want to send 10 messages, but much more). After sending a few messages, we…
