-
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,…
-
Debizium Connector
Hi, I posted to check on this a few months back, but haven't heard any update. Opening this up again to see if there is any news
-
Each Message is not removing from Queue after acknowlegement Flow.Ack(message.ADMessageId)
Hi, I am consuming messages from queue using .net c# . I am using MessageAckMode.ClientAck. It's acknowledging with Flow.Ack(message.ADMessageId) immediately message recieving. But it is not removing each message after acknowledgement from queue. All messages are removing at once after the flow end.
-
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?
-
Does Solace tibco EMS supports JavaRTO as consumer?
Hi Team, We are planning to migrate from TIBCO EMS to Solace. We have done some PoC and planning to Java RTO Messaging API. We have a use case where we need to sync data between Solace consumers and TIBCO Producers. We heard that Solace provides the connector for this but we are not sure if we can use it where the producer…
-
New Access Levels for Event Portal Users to Use Runtime Event Manager
Hi all, 📣 We are pleased to introduce new access levels for Event Portal Users to use Runtime Event Manager. Previously, only Administrators and Event Portal Managers could access the Runtime Event Manager and its environment-focused features. Now, users with the Event Portal User role can be assigned the new EP Runtime…
-
Encountered Error - Timed out waiting for credit to send Message
I using Camel AMQP client to receive messages from other EMS and publish to Solace EMS. However i encountered this error - "Timed out waiting for credit to send Message" if i set jms.sendTimeout=2000. 1) May i know how does broker issue credit to publisher? 2) Can I increase the credit at the EMS broker? at…
-
SEMPv2 API : parameter in __private_monitor__ not in the public monitor
By checking the Solace console I found that the private_monitor__ contains a (query) parameter which is not present (or documented) in the url. Exemple for queue listing filtered by owner:…
-
In the .NET API, why isn't the `CorrelationKey` set on the `RejectedMessageError`?
I have an application with messages sent to Persistent and a session event handler checking for SessionEvent.RejectedMessageErrorstatuses. I wan to add some special handling logic for the scenario where a persistent message is too large (>30MB), but for some reason the SessionEventArgs.CorrelationKey is always null,…
-
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…
-
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 ?
-
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…
-
Need Help in orderbook-distribution-ext-users using Solace C API
SnapShot_Recovery(int Queue) { int argc=9; char *argv[9]; argv[0]="./SnapShot_Rec"; argv[1]="-c"; argv[2]="tcp:172.28.124.40:10986"; argv[3]="-u"; argv[4]="member_fo_prod@od_fo_prod"; argv[5]="-q"; if(Queue == 10){ argv[6]="lvq.nse.fo.od.10.orderbook"; } if(Queue == 11){ argv[6]="lvq.nse.fo.od.11.orderbook"; } if(Queue ==…
-
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 @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…
-
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?
-
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 =…
