-
Getting Error Response (503) - Message VPN Unavailable when restarted my application pod.
Am using solace rar adapter with weblogic to connect with solace event broker. So as per my requirement, my application should retry solace connection if it lost connection for any reason. So test the same, have disable/down my message-vpn through pubsub+ even broker console and retstarted my application pod. once my pod…
-
How to check if field exists or is null in a solace map?
I am using Solace c client api (CCSMP), to subscribe to a Solace topic where messages contain a map. A value for the same key in a map can be a string or null. Is there a way to check if a value for a key is null? If I try to retrieve a value for a key and it's null, Solace API logs "Field Type Null could not be converted…
-
JavaScript API > Error: Operation is invalid for Message Consumer in disconnected
I am new to the Solace Javascript API and trying to read messages from a queue in the PubSub+ Broker Manager. I kept running into the following error when calling solace.QueueBrowser. Uncaught OperationError: Operation is invalid for Message Consumer in disconnected state The funny thing is, when I run the script for a…
-
Legacy SEMP api body for config sync command ```assert-master message-vpn default```
Hello , I am looking for Legacy SEMP api for config sync command ```assert-master message-vpn default``` I was trying this as body """<rpc><admin><config-sync><assert-leader><message-vpn><default></default></message-vpn></assert-leader></config-sync></admin></rpc>""" or…
-
Javascript API > Return a specific range of messages from a queue without consuming them.
I have a use case where I'd like to browse a specific subset of messages from a queue. Example: 100 messages on a queue. We'd like to browse messages 20 to 30 without returning all 100 messages. I don't want to consume these messages so I think a QueueBrowser would suit, however, I can't see support for this in the…
-
Resetting ContentBuffer to its initial size
Hi all, I have one dev-point regarding ContentBuffer. We try to minimize allocation rate and prefer bigger buffers to avoid their expension in case of bigger messages. It looks like the reset() function does not take into account the initial buffer size and works with the hardcoded value 4096bytes.…
-
Solace Beta Opportunity: Join the Solace Community Kafka Crush!
Calling all Solace Community members! Solace's Integrated Kafka Bridge is designed to simplify the deployment and amplify the benefits of a Kafka Mesh and to enable message translation between Solace and Kafka brokers! This feature is in great shape with just a couple of bugs and some work to be done around resource…
-
How do I configure solace mq connector to set mq message format to MQSTR?
It looks like default mq message format is MQHRF2. How do I configure solace mq connector to set mq message format to MQSTR?
-
System User Management Account
Can system user management of Solace Event Portal manage by OpenLDAP ? Is CLI user refers to system user management? Based on , it talks about CLI user and File Transfer User. The event broker always first attempts to authenticate a CLI user using internal authentication. If user does not exist in the internal database,…
-
Is it possible to receive messages from a queue in a FILO way?
Hi, I am working in Boomi where the branded Solace connector is limited to returning 1000 messages from a queue at one time. Usually, this would be okay as you would consume the messages as you go until there are none left, however, for my use case I only want to browse the queue and not consume it. I'd like to retrieve…
-
Mule Solace PubSub+ connector best way to mimic SOLACE:CONNECTIVITY error in MUnit
Hey all, I'm wondering if anyone has any knowledge of the best way to throw the specific Solace errors that will set the error context properly as if the application was running. We are using the PubSub+ connector within a MuleSoft application that is running on Mule 4.4.0 and MUnit tools and runner version of 3.0.0.…
-
Broker v10.5 - SparkplugB 3.0 Compliant
I ran the Sparkplug Compliant test against our 10.5 broker and the result is, it is complaint. The 10.5 broker was running as a hyper-v image. I had to make the changes as detailed at in order for the retain test to pass. I had to increase the VM's memory to 8192 MB in order to make the aforementioned MQTT retain changes.…
-
C# library is allocation heavy on the Send() for message arrays, any chance for improvement?
I have market data app that uses 3rd party C++ library that I wrapped in native C interface and I'm using it in C# app. I exchange memory between native and managed with zero allocations and copies using all the latest and greatest stuff C# has to offer at .NET 6 level. But Solace C# client library is lighting up my…
-
Database and Network Software Details
Database Software Used by Solace: Someone please provide information on the database software utilized by our Solace messaging system? We are particularly interested in understanding the database technology or software that supports the internal operations of Solace. Network Software Being Used: Also, please share insights…
-
How to scale services listening to multiple exclusive queues.
I have an application/service which listens to 10 exclusive queues(let's say we have 10 apache camel routes, each route is listening to one queue) where we are receiving the ordered messages in each queue. I want to scale this service upto 10 pods/instances incrementally. But now I want to have only 2 pods, each listening…
-
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…
-
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…
