-
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.…
-
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…
-
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.
-
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…
-
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…
-
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…
-
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
-
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…
-
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
-
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…
-
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.…
-
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…
-
Solace Beta Opportunity: Solace Terraform Software Provider (Declarative SEMP)
I declare Solace's Hashicorp Terraform Software Broker Provider Public Beta Release 0.9.0 available! See the link to Solace's Hashicorp Registry, customer documentation, and release notes below! Now is your opportunity to try out the Beta release of the PubSub+ Software Broker Provider for Service Automation! This…
-
python using tls : error connecting to a Solace pubsub broker
# Broker Config broker_props = { # "solace.messaging.application_id" : "default", "solace.messaging.transport.host": os.environ.get('SOLACE_HOST') or "tcps://pubsub.preops.nm.eurocontrol.int:5671", "solace.messaging.service.vpn-name": os.environ.get('SOLACE_VPN') or "",…
-
Match (regex) incoming message topic to a list of topics (Python)
Hi, I have a queue which is internally subscribed to various topics. When I read from this queue I can retrieve the original topic. I have a list of actions in my application that run based on whether or not this topic matches that entry: message topic: cars/toyota List of topic actions: cars/bmw > cars/> cars/*/> I think…
-
Receiving Queue Alerts in C#
I'm currently running into issues trying to subscribe to alerts from my queue. I currently have my queue set up where I should be getting threshold alerts when I have 2+ msgs in the queue. From https://docs.solace.com/Monitoring/Subscribing-to-MBus-Events.htm and…
-
Reprocessing Messages
I have a scenario similar to the one mentioned in this post How can I get it to work in JCSMP with spring boot?
-
Help finding reason for Solace Pubsub+ Standard on GCP Kubernetes Autopilot costing so much
Dear all, It's a long shot, but this community has pulled off some amazing solutions, so it's worth a try. We're positioning Solace as part of a business solution for one of our customers. The solution as a whole is deployed in a single GCP Kubernetes autopilot cluster, including the Solace PubSub+ Standard workload. Now,…
-
what is different between amqp request-reply and rest request-reply?
Just wonder, what are the main differences between rest and amqp request-reply? Is it amqp request-reply consider async ?
-
Question on MQTT Authentication
Hi, I am trying to connect using MQTT, I have downloaded the Solace MQTT Sample from and am running the TopicPublisher and TopicSubscriber right now. I noticed that it doesnt matter what username and password I put, I am still allowed to connect to the pubsub service. Why is this so??
-
How can I replay from a specific message ID?
My main purpose is to be able to replay from a specific message. I want to be able to keep track of which was the last message that was successfully processed, so that I wont have to replay from the start or replay the whole day's worth of message. I think that in order to do this, I would need to be able to find out how…
-
Distributed Tracing is now Generally Available!
I'm thrilled to announce that Distributed Tracing is now generally available for all customers and prospects. The recent release of PubSub+ 10.2.0 included distributed tracing! Thanks to all the customers who tried out our early access release of distributed tracing! Our Early Access release of distributed tracing is now…
-
Connecting to Solace
Hi All, I am trying to connect to solace using the below details but have to use a truststore instead of a password using C#. SessionProperties sessionProps = new SessionProperties(); sessionProps.Host = "********"; sessionProps.VPNName = "*******"; sessionProps.UserName = "*******"; sessionProps.SSLValidateCertificate =…
-
Please Read Before Posting
Thank you for starting new discussions and asking questions. The more you contribute, the better this forum becomes. Here are a few tips to help you create great discussions: * Make the discussion title or question as descriptive as possible. A good discussion title is a short preview of your post and is what gets people…
-
Specify Spring Cloud Stream Error Handlers though application configuration
In the current scheme of things, you would be wiring the error handlers through @ServiceActivator annotation. The annotation parameters helped distinguish global versus binding-specific error handlers. If you notice, the association is captured in the code, and a change would require code-level updates. In the…
