-
Using NodeJS to "eavesdrop" on Microgateway messages
Hi there, I have a Microgateway set-up and I'm trying to eavesdrop/ audit messages using NodeJS but I'm encountering some apparent limitations with the API. How is it possible for me to access HTTP Content-Type, Content-Encoding, Accept-Encoding headers using NodeJS? It's common for REST payload to be encoded using gzip,…
-
Group name exclusive getting appended to queue name
Hello, my group name is getting appended to end of my queue while connecting, here is my .yml, Any suggestions why this is occurring ? Do I need a compatible version for this change? bindings: #The bindings section is used to define your input and output channels. read-in-0: destination: Sakshi_Test group: exclusive #The…
-
Solace HA Active/Standby Failover Test
Initial test, by referring to https://docs.solace.com/Configuring-and-Managing/Validating-Failover.htm#managing_router_redundancy_2753819523_330776. Manage to failover and able to see its messages flow. When 2nd attempt to test above scenario, from Primary Event Broker to Secondary Event Broker, it seem like the session…
-
Solace Developer Spotlight: Carlos Rodriguez Iturria
Hometown: Melbourne, Victoria, Australia Years of being a developer: 20+ Primary programming language(s): Java, JavaScript, Python, Golang, Shell, Scala, Dataweave, etc. How did you start as a developer? Everything started when I was a kid and wanted to understand how Gorilla BAS worked. So, I got into QBasic at that time.…
-
Consuming messages from custom dead message queue is not working since version 9.10.0.21
We have a queue that has our own defined dead message queue. We use to able to consume messages from that dead message queue after upgrading to version 9.10.0.21 its no more possible to consume. Same code can consume message from regular queue. Using sol-jms 10.12.1 for client.
-
Will there be support for OAuth2 JWTs signed with EC256?
Hello, we evaluating Solace as a Pub-Sub-Broker for our infrastructure. We want to use our authorization server with the OAuth2 Client Credential Grant for client authentication and scopes for authorisation. The server issued JWTs signed with the EC256 algorithm. I understand that the OAuth provider is only available with…
-
Steps to upgrade solace to latest version
Dear All, Please help to provide steps to upgrade the solace to latest version. PFB current version in detail: show version Process Release Build date CLI 8.2.0.8 DataplaneMgr 8.2.0.8 Jun 27 2017 14:51:56 IST Controlplane 8.2.0.8 Jun 27 2017 14:51:56 IST Managementplane 8.2.0.8 Jun 27 2017 14:51:56 IST Current load is:…
-
Remote addr: solaceuat.bos.group.intranet:55443) - Error Response (400) - Already Exists
Want to consume solace message from que using multiple consumers and multiple threads public Connection connection() { Connection connection = null; javax.jms.Session session; try { logger.info(">>>>>>>>>>>>>>>>connectionFactory.setHost:" + solConnectionFactory().getHost());…
-
Complete this short survey to help us know the community better. You may also win a $100 voucher!
We’re constantly thinking about how we can make this community a better place for you to discuss Solace PubSub+ and engage with other developers. In order to do that, we have prepared a short survey so that we better understand your needs. Please fill in the survey. It takes only 4 minutes. You will be entered for a chance…
-
Spring Cloud Stream - Solace JMS Client Passwords configuration
Hi All, Let me share steps we use for us, 1. We have autoconfiguration for queues and topics, (using solace binders(Sink, Source, StreamBinders)) 2. We have solace auto configurations 3. Solace clients( random generated clients) connects to queues 4. I have to decrypt the password and inject the same password in runtime by…
-
Request/Reply with dynamic topics after authenticating with Oauth2
Hye guys, I' ve set up a request/reply in using the message gateway. Everything runs fine. Now I want my user first to authenticate on my keycloak server and then make the request/reply just for his user. But there are 2 things not completely clear to me. Do I have to do this with a dynamic queue or topic that includes for…
-
JCSMP send timeout?
With the JCSMP api, the XMLMessageProducer.send(...) method blocks while the client is reconnecting to the broker. In a situation where the broker is unavailable for a while and the client is continually reconnecting, is there any way (or common practice) to implement a timeout on the send? I'd like to be able to fail or…
-
Default vs Compressed Connection
Hello everyone! While using the solace pubsub+ broker on docker as a localhost, I noticed a very strange observation. The default connection performs better than the compressed connection: Whereas, while using the cloud broker, the observation is opposite: Since the compressed connection compresses messages before sending,…
-
Is it allowed to include C libs in a public Git repository?
Hi, I'm creating a tool that reads messages from Solace and saves them to a database. I'm using Solace C SDK from Rust. I manually downloaded Solace libraries from https://solace.com/downloads/?fwp_downloads=solace-apis Now I would like to publish my tool to a public Git repository. But since it won't compile without the…
-
Best Practices Gems here folks
I'm not sure if this has been shared before, but I don't see any harm of popping this up to the surface for all of us. This is where we put a compilation of best practices for different areas around designing an event driven architecture with Solace. Enjoy! https://docs.solace.com/best-practices.htm
-
synchronizing onComplete event for a solcache subscribe request
Happy new year all, I want to find a way to synchronize the onComplete callback for a solcache sub request. cacheSession.sendCacheRequest(reqId, solaceTopic, true, CacheLiveDataAction.FLOW_THRU, new CacheRequestListener() { @Override public void onException(Long arg0, Topic arg1, JCSMPException arg2) { LOG.error("Consumer…
-
SDK Warning while using Solace C API
Hello everyone, I am new to using Solace. I am trying to execute the sample HelloWorldPub and HelloWorldSub applications as downloaded from the Solace C API. When I try to run them, I get the following output: HelloWorldPub: HelloWorldPub initializing... SDK WARNING Fri Jan 29 16:47:17.960 2021 solClientSSL.c:2264…
-
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…
-
How to check the publisher of a TOPIC?
Hi All, Can you please share a command or SEMP query to get the publisher client details for a particular topic? We can view the sender of a queue using ingress flow on the client but I don't see any option for a topic publisher in soladmin/pubsub+ manager.
-
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…
-
Publish / Subscribe - REST Way
I have been following article https://tutorials.solace.dev/rest-messaging/publish-subscribe/ for long time but not really able to get it 100% working. Below are some of the issue I am confused with 1. Operational state of my RDP, Rest Consumer and Q is down but they are enabled. 2. Node Server is up and running and below…
-
Spring Cloud Stream publishing messages
I have heard that SCS should no longer be used together with flux (flux destroys that: retry handling, error handling, transmission confirmation). With StreamBridge messages can be published. But in my opinion the StreamBridge is not quite consistent with the other declarative and functional handling of SCS. Are there…
-
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
-
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…
-
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…
-
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…
