-
Solace Try-Me CLI (stm): A sleek command-line tool for messaging Solace PubSub+ Broker
Thrilled to introduce a new command-line tool Solace Try-Me CLI, simply called stm that brings the robust messaging capabilities of the Solace PubSub+ broker right to your fingertips! stm designed specifically for interacting with Solace Broker! This standalone tool is perfect for anyone looking to dive into messaging…
-
TestContainers for Solace PubSub+
I am excited to share an update on Testcontainers for Solace PubSub+ module. For those who have not worked with Testcontainers, let me help you with the introduction Testcontainers is an open source framework for providing throwaway, lightweight instances of databases, message brokers, web browsers, or just about anything…
-
PubSub+ Messaging API for Python with Mac M-series Support - Now Available
I am pleased to announce that as of the latest release of our Python API (v. 1.7.0) it now has support for Mac M-series processors so developers can use the API when developing applications on the latest Mac hardware. It can be downloaded through all the regular channels such as: Solace Downloads Page: Solace Products…
-
Introductions Thread - New to the community? Start here!
Intro Hi all, if you've joined recently you may have seen a welcome message from me in your inbox but I figured a great way to get to know folks here would be an intro thread. As we share Solace related knowledge and learn from each other, let's get to know each other! Name or handle (only share what you're comfortable…
-
Solace Beta Opportunity: Solace Terraform Appliance Provider (Declarative SEMP)
Now Available! Solace's Hashicorp Terraform Appliance Provider Public Beta Release 0.9.0 is available from the Terraform Registry! Now is your opportunity to try out the Beta release of the PubSub+ Appliance Provider alone or in combination with the PubSub+ Software Broker Provider for Service Automation! The appliance…
-
New Graphical Designer in Event Portal
Hi all, 📣 We are pleased to announce the availability of the new graphical designer in Event Portal. This feature is being delivered in phases, with this first phase providing a graphical view of the event driven architecture for each of your application domains. ⭐️ The graph displays the latest, non-retired version of…
-
How to configure the @JmsListener and receive Solace Topic messages ?
Hi @marc , I followed your tutorial in this thread, how to listen to Solace Topic via JMS. I tried to configure it in my program as well, but I got an error of : unknown endpoint (503: Unknown Queue). I just started learning Solace, can you help me find the issue ? Think you~ This is my JMS configurations:…
-
How to achieve Topic + Queue mechanism using NodeJS & AMQP
Hello, I'm using NodeJS as my tech stack and created a Queue and that queue is subscribed to the topic. Mechanism: Publish a message to the topic and subscribe to the msg from the queue, basically Topic to Queue Mapping. Query: I want to build the above mechanism using the AMQP protocol with NodeJS. Tried Approach: I've…
-
Shared Subscription Syntax for MQTT
Hello Solace Community, I have a question regarding the usage of shared subscriptions with an MQTT client. I found two different prefixes in the documentation and am curious to learn which is used in which case. I found in the documentation the following hint (see:) : Syntax of Shared Subscriptions A shared subscription…
-
how to configure the RDP reset-comsumer remote retry times limit ?
I have configured the RDP reset-comsumer remote retry delay, but when message delivery got failure due to 503/504, it keeps retrying and it doesn't look like it will stop. I want to set it to stop after 10 attempts. How can I configure it?
-
Protocol difference in publishing (AMQP vs REST)
Hi Community, We are using PubSub+'s multiprotocol capabilities for inbound and outbound communication. There are many general-fundamental differences between AMQP and REST in terms of usage however I would like to understand what difference it makes when we choose among them while "publishing" to the broker? (in terms of…
-
How to solve this error: Received disposition with role=receiver
I using AMQP Camel to read message from Queue A, add header to the message and send to topic B. There will be 200 message every 300 millisecond. Based on the log file, the JMS MessageConsumer closed every 1 seconds. I don't know why. Can someone give me hint how to prevent the MessageConsumer to close ? Camel Route…
-
Easy aliases for CLI and shell with Docker!
Are you tired of typing docker exec -it solaceXYZ cli every time you log into CLI? I know I am! Try adding these aliases to your .bash_alias (or whatever) file: alias cli='docker ps | grep solace-pubsub | head -1 | cut -c1-8 | xargs -I id -o docker exec -it id cli' alias shell='docker ps | grep solace-pubsub | head -1 |…
-
subscribe to multiple topics inside same session?
TopicSubscriber.java (https://github.com/SolaceSamples/solace-samples-jms/blob/master/src/main/java/com/solace/samples/TopicSubscriber.java) gives a good intro to subscribing to a single topic. What if we want to subscribe to multiple topics ideally with a listener attached to each of those subscriptions. Do we have…
-
Azure HA failover load balancer service issue
Greerings, I have an azure deployment where all 3 pods are up, redundancy, config-sync etc..., pod0, pod1 and pod2. We are using an azure load balancer service for clients to connect to smf ssl port. This works fine until pod0 goes down and pod1 is in charge. It looks like all the requests keep going to pod0 since it's pod…
-
How to fetch the Non durable queue details via SEMP API
when i use SEMP API to fetch all the queues details from my vpn, found that Non durable queues is not included. is it as designed that non durable has been filter out from the SEMP API get queues return result? or is there a SEMP API can be use to get the non durable queue details?
-
Selectors in node js
I see that selectors are not available in javascript API Will this feature ever come to javascript ? What are some alternatives options for consuming messages based on specific message headers in javascript ?
-
How to send NACK(Negative Acknowledgement) using java API
Hi Team, Need your help to find the solution. Current Implementation details, SolConnectionFactory connectionFactory = SolJmsUtility.createConnectionFactory(); --> for create connection factory using host , vpn,trust store,keystore with auth scheme AUTHENTICATION_SCHEME_CLIENT_CERTIFICATE this.connection =…
-
MessagePublishReceiptListener is not getting the acknowledgement python API
class SolaceMessagePublishReceiptListener(MessagePublishReceiptListener): def __init__(self): self._publish_count = 0 @property def get_publish_count(self): return self._publish_count def on_publish_receipt(self, publish_receipt: 'PublishReceipt'): with lock: self._publish_count += 1 print(f"\tSOLACE -- \n", f"\tMessage:…
-
Can we use Solace connection pool for node.js application using solaceclient library
Hi Team, we are building an Azure Function using node.js. This azure function is connecting to Solace using SolaceClient library and publishing a message into Solace topic. Currently, we are open and close the connection for a request. We want use the Connection Pooling concept in Solace Connectivity. so that, same…
-
cluster external links
Greetings i have 2 deployments in azure configured, clustered together where the external links were working fine but recently show up as "internal link missing between solace1 and solace2". The external links show as "Down" in Operational State but the channels show as "Up" in Operational State Suggestions please ?
-
Spring Cloud Stream - Open telemetry Manual Instrumentation
I am trying to see any possibility to do manual instrumentation on scs consumer and publisher application. If there a possibility to achieve this with jcsmp opentelemetry dependency?
-
python qpid-proton cannot access solace broker after rename Message VPN
Hi everyone, I have some problems with connecting to solace with qpid-proton python. I connected to Solace that isn’t running on my local machine but other server, and I could send the message into the queue with the subscription topic and also receive the message from the queue successfully for a while. All I specified…
-
Regarding issue with the dll
Hi Team, I am trying to publish a message using a C# code. It is compiling correctly, but when I run it. It gives me error. By the looks libsolclient.dll is missing. Can you please help me?> Error Message System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. --->…
-
C# - Solace Queue Message not reading and missing sometime
I have referred sample code provided by the Solace team for implemented Pub/Sub Queue message (https://github.com/SolaceSamples/solace-samples-dotnet) Sample code is implemented part of Microsoft .Net 6 Worker service and scheduled to run every 30 mins. I am facing new issue and i really don't know what went wrong in my…
-
How does Queue or Topic Proxy differ from DestinationImpl?
In my previous post I am facing a class cast exception while writing the consumer code. java.lang.ClassCastException: com.solacesystems.jms.ra.outbound.QueueProxy cannot be cast to weblogic.jms.common.DestinationImplStack Trace for RuntimeException was:java.lang.ClassCastException:…
-
handle Throw error in Pub/Sub Pattern in Javascript
Hello, I am trying to get my head around how error with a publisher in javascript. When I invoke a failed connection via false credentials the following code snippet is executed in the Publisher code: publisher.session.on(solace.SessionEventCode.CONNECT_FAILED_ERROR, function (sessionEvent) { publisher.log('Connection…
-
java.lang.ClassCastException: Solace QueueProxy cannot be cast to Weblogic DestinationImpl
Hey Guys, I was recently introduced to Solace and am trying to deploy a sample Pub/Sub application using JMS API on a local Weblogic server but ran into this class cast error which I cant seem to find a solution for. I have created a topic "MyTopic" which is subscribed by a queue, "MyQueue" and also configured the JNDI…
-
Content resolution example with Spring Cloud Stream
The Spring documentation mentions one of the core features of the framework: It tries to automatically convert incoming message payloads to type Person with the following code: @Bean public Consumer<Person> log() { return person -> { System.out.println("Received: " + person); }; } My attempts to have the incoming message…
-
OpenTelemetry Agent for Spring cloud binder
I would like to autoinstrument my scs based application. For trial I have added opentelemetry agent latest version and started my application- But traces are not generating. Is there any separate agent available for SCS to to auto-instrument ?
-
Solace Python API on Mac M1 ?
Hi, I tried to install Solace Python API on Mac M1 and run some scripts with it. pip install solace-pubsubplus ⇒ Successful Running some script: Unable to load core library from [/Users/uherbst/Library/Python/3.11/lib/python/site-packages/solace/messaging/lib/macosx-x86_64/libsolclient.dylib]. Exception:…
-
Unable to start the Solace pubsub in podman
I am trying to start the pusub in podman, but when I run the below command the container is in running state and I am unable to access the console in browser. Command: podman run -u 1000:1000 --ulimit nofile=524288:524288 -p 1943:1943 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env…
-
Golang Parallel For One Consumer?
How can I increase the number of connections for a consumer using pubsubplus-go-client? We pass a callback to ReceiveAsync for a consumer via PersistentMessageReceiver, but only one message is processed at a time.
-
How to get a Map (java.util) of internal properties of a JCSMP message (in java)
When calling the `dump()` method on a message (BytesXMLMessage, with JCSMP API), there are two kind of information: 1. metadata, which are internal headers (replicationGroupMessageId, traceId, messageId, etc…) 2. message body in binary format I would like to know if it's possible to get the internal properties in a Map…
-
How to see information on each message in a queue
Problem You want to check the messages you are sending for error checking or validation but don’t know how to do that. Prerequisite Download Solace Java or .NET APIs Download SDKPerf Solution You can do that in two ways: * Option 1: Use a queue browser with either the Solace Java or .NET API or SDKPerf * Option 2: Use…
-
Pods are not running and failing very often
Hello Team, I have deployed the pubsub+ HA using helm chart in the GDCE environment (Google Distributed Cloud Edge) which is GKE cluster. There are 3 nodes, hence 3 pods are suppose to run. but 2 pods are failing very often. and one pod is about to start, but not starting. One of the Pod log says: "ERROR:…