-
Solace in typescript on node server
Hi we’ve implemented a solace topic subscriber on our node server with solclientjs. We currently working with requiring a js module to handle all the solace stuff and that works. But we’re looking to update this to tyoescript. Would be awesome if you can add @types not really typescript at the moment. Could not find a…
-
Solace Developer Spotlight: Dunith Dhanushka
Hometown: Galle, Sri Lanka (2 hours of driving from Colombo, the capital.) Years of being a developer: 12 Primary programming language(s): Java and Python How did you start as a developer? I started my programming career back in 2005 with Visual Basic 6. I was playing around with the GUI-based applications first. Then I…
-
Selecting queues from SEMP monitor api where message count > 0 ?
Is there any way to query queues from SEMP and filter based on the message count? If I try to add a where clause to the URL with msgs.count I get the following error: "where query error: Collection 'msgs' not allowed". If not, I'll just load all queues and filter in my application. Thanks, Pete
-
[New blog post for developers] New Java Messaging API Now Available
Last month Solace released version 1.0 of a new messaging API for Java. Why is it version 1.0 when we already have a Java API, you might ask? This blog post breaks that down first, then introduces the new one and explain why it’s such a big deal. This blog post covers the following: * A Tale of Two Java APIs * Why a Second…
-
Detect which services are alive
Hi, we have several services which use Solace to communicate. We also want to notify users if some service is not running. To do that every service publishes a heartbeat to a topic service-name/heartbeat and when the heartbeat stops we assume that the service is not running. This is working, but I'm wondering if there is a…
-
downgrade of software brokers?
Hi Experts, I have a quick quesiton. Is it possible to "downgrade" software brokers? I found procedures for "appliance" but not "software". Many thanks in advance, Kia
-
spring cloud stream
compile("com.solace.spring.cloud:spring-cloud-starter-stream-solace:3.1.0") when i add this dependency to my project using spring boot 2.3.12. Its downloading 2.4.3 jar also ( when removed it doesn't ) where as i tried 2 other project its not the case over there they still use 2.3.12 and does not download 2.4.3 and use it…
-
Unable to create a Polling Consumer
I want to create a polling consumer which is written in myFunction the queue is : Test and topic is abc/test **I have also autowired PollableMessageSource source and used this polling source in my function however, it is not fetching values from topic, is my configuration incorrect? *** spring: cloud: function: definition:…
-
upgrade procedure of monitoring node
Hi experts, I have a redundancy env including two msg-routing nodes and one monitoring node as Active/Standby, and want to confirm upgrade procedure(s) of the monitoring node, which is not mentioned in the doc below. https://docs.solace.com/Solace-Appliance-Upgrade/Upgrade-Redundant-Appliances.htm#With Could anyone help me…
-
Trying to understand Consumer Ack Window
I think that I have totally misunderstood the consumer flow ack window, and am trying to figure this out. Does the consumer ack window dictate the max number of messages unacked by the JCSMP API, or by the application? I have client acknowledgement enabled, and want to throttle the application so that the broker does not…
-
Pull message from a queue on an adhoc basis
Hi, I have a requirement to use spring cloud stream binder for solace to connect and pull messages from a queue. The application should not listen to that queue continuously instead it should try to pull the message based on a scheduled time interval. Could you pls help me how to achieve this with minimal java code? Thanks
-
Do I need to close my JCSMP consumer/session on application shutdown?
I generally like to close resources gracefully when shutting down an application, and ran into a scenario where my queue consumer still had an outstanding message that it tried to ack() after the consumer had been closed, so I got the message "Attempted an operation on a closed message consumer." If upon shutdown I instead…
-
[New Podcast for Developers] Microservices For Everyone w/Tom Fanara: Ep 03: Real World Tech
In this episode Tom interviews Jesse Menning, CTO Software Architect at Solace. Jesse discusses Event Driven Architecture (EDA) for microservices. EDA is a best practices way of separating the communication between microservices with an event broker! Thus creating layers of knowledge on really what's happening in your…
-
SEMPv2 - Your Solace Broker comes with the OpenAPI docs!
Did you know the Solace PubSub+ Event Broker allows you to access the openapi spec for the SEMPv2 API directly from it? You can access human readable docs at: * Config API - http://<HOST:PORT>/SEMP/v2/config/help * Action API - http://<host>:<port>/SEMP/v2/action/help * Monitor API -…
-
[Weekly Quizzicle] Which subscriber provides no delivery guarantee?
-
When we create new consumer then it is creating queue in fomart scst/wk/exclusive/plain/*
How to avoid creating this queue because it creates extra queue. I want to listen on queue which is already created and just map to it
-
Use LVQ to run in Master/Slave mode
Hi, I wanted to run my service in 2 regions in master/slave mode. Is it possible to use an LVQ to achieve this? What I am thinking is that whenever the service starts it will try to connect to an LVQ and as per my understanding only one can have access to it. (Is it correct assumption?) If so, that process will act as a…
-
[Weekly Quizzicles] message.acknowledge() only acknowledges message has been received and consumed
-
Discard indications and topic dispatch
Hi, how does discard indication (in .NET) work together with topic dispatch? According to the documentation if my egress queue contains * message A to topic T (top of the queue) * message B to topic T2 * message C to topic T and gets full then message A will be discarded and discard indication will be set on message B? But…
-
@StreamListener(target = Sink.INPUT, condition = "headers['eventType']=='EmployeeTransferredEvent'"
I am using latest version of solace streaming and want to filter messages based on header but I see @StreamListener is deprecated and how to achieve this with properties file i have seen queueAdditionalSubscriptions but its filtering based on topic and not on header properties. solace: #The solace bindings section allows…
