-
Non-Exclusive Queue using AMQP
Hi, can it be possible to create non-exclusive queue using amqp in solace ? I am exploring Apache Qpid JMS 2.0 over AMQP 1.0 I checked solace-samples-amqp-qpid-jms2/QueueConsumer.java at master · SolaceSamples/solace-samples-amqp-qpid-jms2 (github.com) and it creates an exclusive queue and connects the consumer to the…
-
Window size(prefetch) control of unacknowledged message in Node.js
The messages in our system need to be processed in sequential (we expect the message to be handled one after another) and we are trying to build a queue consumer with the liberary solclientjs. (https://www.npmjs.com/package/solclientjs) I read some blogs and posts that mentioned two keywords the flow windowSize and…
-
Clarifitcations regarding sticky load balancing example architecture by Mathew Hobbis
Hello, I have read the example implementation of sticky load balancing by Mathew Hobbis on this link and am slightly confused about a few things. Was hoping I could get some answers to the following: Inquiry 1: Regarding "Consumer Group Clients", is this the same client as LBG Client? or is it a different service? Question…
-
C# consumer flow dispose
Hi I'm new to Solace + this is my first post, so be gentle :D I'm building a worker (C#) that consumes messages off a Solace Queue using the SolClient messaging API. On application shutdown, I attempt to stop & dispose the flow. See code below: _flow = session.CreateFlow(flowProperties, queue, null, HandleMessageEvent,…
-
Channel immediately getting closed after connecting to host
main impl.TcpClientChannel:55 - Client-1: Client channel (smfclient 1) starting KA timer main impl.KeepaliveTimeoutHandler:28 - Created new KA timer handler main impl.TcpChannel:300 - Scheduling KA timer in 3000ms main impl.ChannelOpStrategyClient:381 - ** Got CLIENTCTRL, updating P2PINBOX to…
-
1:n behavior using AMQP
Hi, we have multiple instances of application and when we publish a message, all instances should get the message. we can achieve the same using native soalce api using queue and topic. We create multiple queues and subscribe the same topic to each queue. And each instance of the application consumes from the respective…
-
Non Exclusive Queue Behavior using MQTT
Hi, we have multiple consumers connected to a durable non-exclusive queue and when we send a message to the queue , only one of the consumers gets the message. Can it be possible to achieve the same behavior using MQTT / java-paho-mqtt ?
-
Durable Queue Inactive Consumer Indication
Hi community, we are exploring the Active/Inactive Consumer Indication feature of solace queue. We have created a durable queue at Solace and connected two consumers with the queue. We have tried with Java and Nodejs. (1) JAVA JCSMP API public void handleEvent(Object source, FlowEventArgs event) { System.out.println("Flow…
-
How to get the number of current consumers of a durable queue ?
Hi, is there any native API (Java, NodeJS, GoLang) by which we can get the number of current consumers of a durable queue ? one way is to use SEMP API ("GET /msgVpns/{msgVpnName}/queues/{queueName}/txFlows"). We are looking if there way way to do the similar task using some native API.
-
How can we achieve solace message delivery of at least once with variable number of pods?
We have a kubernetes deployment having 2 pods. We want to send messages to both these pods in 1:n way (each message should be received by both) and each message should be delivered at least once(QoS1). To achieve the same, we have a topic and 4 queues created beforehand. All four queues are subscribed to the topic and…
-
Spool Over Quota. Router limit exceeded
I am using a guaranteed message queue. This is sit under the default VPN. The `Configured Quota` is 5,000 MB for the queue. The `Configured Quote` is 1,500 MB for the VPN. I cannot push to the queue when the message size hit 1,500 MB. I updated the `Configured Quote` for the VPN to 10,000 MB but I still cannot push message…
-
How to access the Solace CLI
I am using docker image to run the solace broker. The image is solace/solace-pubsub-standard:latest . I would like to access the CLI and for example check the current version or log checking. I followed the steps but it seems that there is not enough access right for me. I would like to ask what is the correct way to…
-
Event Broker version availabilitry
Hi @marc I have seen the event broker version available in trial version of pub sub+ cloud is 9.10.0.23 whereas the latest one is 9.12.1.17. Can you please suggest why the same is not availbale in trial version. Would like to do some POC on Oauth using SEMP Regards Prosenjit Das
-
Native C# Client for Web Sockets
Hi all! I need to connect via WebSockets to an on-prem Solace Broker from my native app (UWP written in C#). I also need to add I the Connect() HTTP request a specific HTTP Header "Authorization" with a Bearer token that I generate in the app. I cannot see a way to configure the Solace C# SDK to perform such a custom…
-
How to use the guranteed publisher
Hi all, I am trying out the guranteed_publisher.py: https://github.com/SolaceSamples/solace-samples-python/blob/master/patterns/guaranteed_publisher.py There is a callback on_publish_receipt: https://github.com/SolaceSamples/solace-samples-python/blob/master/patterns/guaranteed_publisher.py#L43 I see that is the…
-
Each time my consumer/subscriber application is redeloyed, the messages are redelivered from the sta
Let us say I have received/ processed 18000 messages over subscriber/ consumer. The subscriber has been redeployed, now I see all the 18000 messages being sent across to the subscriber all over again. Why is this happening? My deployment model is a zero downtime RTF based
-
What problems solace solves when I use an Async API
What problems solace solves when I use an Async API where I clearly define the spec that has the channels , payloads , whats the role of Solace when you use an Async API.
