-
Unable to Subscribe Topic in Solace Local from Streamset Pipeline (JMS Producer)
I have set up Docker containers for SQL Server, StreamSets, and Solace, following the steps outlined in the blog https://solace.com/blog/change-data-capture-solace-streamsets-dr/. My goal is to enable Change Data Capture (CDC) and stream data from SQL Server to Solace via StreamSets. In the setup, I'm able to configure…
-
Observing DNS resolution failed when connecting to external application through RDP for .com url
We are currently using Solace 10.4.1.121 version deployed through Podman and observing this issue for many integrations whenever .com url is involved. Flow : MuleSoft—>EMS(Solace RDP)—>MuleSoft(.com url) - Not working But the same integration, when APIGW is involved in between it is working fine. Flow :…
-
"SYSTEM_AD_SPOOL_FILES_EXCEEDED" occurred while running Event Broker.
Hello, "SYSTEM_AD_SPOOL_FILES_EXCEEDED" occurred while running Event Broker. I have some questions regarding the issue. Q1. What is the definition of SPOOL_FILES? Q2. Where is the SPOOL_FILES stored? or is it in the 'spool' directory? Q3. How many SPOOL_FILES are created and is there an option in the CLI to control them?…
-
Can we copy files from Solace queue
We have a requirement to copy a csv file from Solace Queue to an Azure Data Lake location. I am new to Solace and I do not know if there are any existing services to directly copy a file from a queue instead of consuming the content of the file as a message and copying that. Please advise.
-
How can you track the topics being routed via DMR Subscriptions between an event mesh?
Trying to get a better understanding of our event mesh which is rather large and uses a lot of DMR subscriptions throughout. As a result - sometimes track the initial source of a message across the mesh can be quite difficult. I'm trying to find either a CLI command or SEMP query to get a list of DMR subscriptions arriving…
-
Connecting With NSE
Hi Guys, i am new solace user where i'm connecting with nse but i got error tcp_TxRx callback for session '(c0,s1)_username' in channel state ESTABLISHED: Subscription ACL Denied - Topic 'queue name' Subscribe: Response code: '403'; Flags: 'c'; , client name 'MSPL-BP5-21/5828/00000001/t7ZE4yY8zL', VPN name '***', peer host…
-
Issue in accessing the Solace Software Event Broker CLI
We are working on setting up the Solace Software Pub Sub + Event Broker of Standard Version 10.4.1.121 in lower environments. We are observing "Access Denied"" error when trying to login to the cli using the below command. podman exec -it solaceusqa1 /usr/sw/loads/currentload/bin/cli -A However, we are able to login to the…
-
Disable consumer at solace broker
Can we control enabling & disabling of a consumer at solace broker end. Like if i have 3 consumer of my queue i.e c1, c2 and c3 (non-exclusive queue) but i want that only c1 & c3 will receive the messages . So, it is possible that i control it at solace broker only? (FYI- my consumer is MDB, listening to pubsub+ event…
-
Spring JMSListener fails all the messages in the queue
I have a queue endpoint that's configured with non-exclusive access redelivery enabled with the default redelivery delays delivery count of 10 a dmq queue name non partitioned and pretty much everything else is the default values. I also have a springboot message listeners that has a concurrency of 1 is auto acknowledge…
-
Is there any way to copy queues from one event broker to other
I am planning to create event broker service for PRODUCTION environment. Existing event broker instance I used for DEV and QA purpose. I know cloning whole event broker service but not sure about if we do have any way to copy the queue from one event broker to another.
-
PubSub+ Maximum Message VPNs
Hello. My team and I require a Message VPN for each and every one of us, all of which should be on a single Solace instance (so there's no resource wasting). I tried reducing all the settings (of the VPNs) I could get my hands on to the minimum possible, but i cant seem to create more than 3 VPNs (including the default…
-
consumer setting to connect solace system
What are the installation to be done at consumer system( windows) to connect solace system
-
Which correct protocol should I choose?
Hi! I'm new working on Solace PubSub and despite the fact I've been reading a lot, I didn't understand which is the correct protocol I should use. For example, I have an application publishing more than 1k events per hour on dynamic topics. It can be company/salesorder/usa/123/234, company/salesorder/usa/453/1/45,…
-
spool, spool-cache, and spool-cache-backup
I have reviewed the documentation on spool, spool-cache, and spool-cache-backup but need a more detailed explanation of their respective roles.
-
About spool size
I want to set the spool size. If the OS has a separate disk capacity of 1TB and the spool area is mounted separately, could you provide the optimal ratio for spool, spool-cache, and spool-cache-backup?
-
Number of Unacknowledged Messages
Hello All, I am trying to clean up the shutdown of my service, and delay it until all messages have been processed. I call the Stop() method on all of my IFlows, but I then want it to wait until the number of Unacknowledged messages drops to 0. I can see in the console the number of unacknowledged messages on the consumer,…
-
Drain Queue via MQTT
Hi everybody, I'm trying to drain a queue via MQTT. My queue is confingured like this: Following https://docs.solace.com/Messaging/Reserved-Topics.htm and https://docs.solace.com/API/MQTT/MQTT-Topics.htm#Special I created a client that subscribes to the Topics (_P2P/QUE/test-queue, _P2P/QTMP/v:default/test-queue ) that…
-
Is there a way to enable Audit logs in pub sub+ event broker and fetch those logs?
I want to enable audit logging in pubsub event broker which I am running it as docker container. Is there a way to do that? I see Audit logs are there in pubsub cloud but is it available in pub sub event broker? #audit
-
Is there a way to enable Audit logs in pub sub+ event broker and fetch those logs?
I want to enable audit logging in pubsub event broker which I am running it as docker container. Is there a way to do that? I see Audit logs are there in pubsub cloud but is it available in pub sub event broker?
-
Troubleshooting frequent / high amounts of fragmentation on an event broker
Hi all, Trying to get a better understanding of fragmentation and potential culprits of high amounts of fragmentation occurring in a particular event broker. Defragmentation is running daily on a schedule, not threshold. But we are seeing within an hour after defrag runs successfully the estimated fragmentation reaches 99%…
-
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…
-
Showing exemplars on Prometheus
Hi All, I am trying to use prometheus to display data with exemplars to show traceID but I cannot seem to get it to display the exemplars I used this repo as a base and placed in prometheus and grafana tempo. #Docker Compose version: '3.5' networks: solace_msg_net: name: solace_msg_net external: false driver: bridge…
-
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 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…
-
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…
-
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…
-
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:…