-
How to empty a queue with 200+ messages?
Hi all, We are using Solace in combination with Boomi. We're looking for a solution to empty a queue quickly. No matter how many messages are in that queue. From the Solace Cloud console, the max is 50 per page. JMS Toolbox is refusing to empty a queue when it contains 200+ messages. How to solve this? Ideally, we would…
-
Garanteed Subscriber problem: "Emitter rejects listener for no-name event: undefined"
Hello everybody, I hope I am posting this on the correct Category, correct me otherwise. I am trying to subscribe a Solace Queue in order to get it's messages and redirect them to a specific endpoint which will later process it's information. For that, i've made a NODE JS service which uses the GaranteedSubscriber example.…
-
Consume existing Solace Queue using Python
Hi @marc @Tamimi we have existing solace queue with topic subscription enabled. need to listen and print message flowing to that queue. tried below code & got error, please help. persistent_receiver: PersistentMessageReceiver = messaging_service.create_persistent_message_receiver_builder()\…
-
In Spring cloud , i would like to read data from pre-define queue.
Currently spring cloud app will create the queue "scst/an/some randome-id/plain/myConsumer-in-0" at server startup (some thing similar), Since i already have a queue and queue has some persistence message so how to command spring cloud to use existing queue for subscriptions.
-
error while creating receiver flow: Max clients exceeded for queue
We are currently building the Solution to integrate with Solace. We are still developing and not using Solace in Prod. Currently only a few developers uses this Solace and we donot have that many Sessions or connections to Solace. According to the Dashboard, it is using only 2 Active connections (But actually we have…
-
How to Publish messages in JSON Format in PYTHON ?
Hi Myself ranganath working as software engineer in standard chartered bank my requirement is to publish message in JSON Format in python . Kindly assist.
-
System scaling using helm chart
Hi. I have configured solace in my dev env(using helm chart) and currently it only allows upto 100 queues/endpoints creation. To scale I tried setting systemScaling values to : But it doesn't seem to be working. I setup solace in my laptop in docker and added these as --env system_scaling_maxconnectioncount=1000 --env…
-
Queue binding with Service Unavailable status
I new to Solace and I'm doing some exploration to see how this would fint in my organization. The use case straight forward, post a message from a producer to solace queue and have solace forwarding it to rest consumer. This is bit complex setup with private AWS API GW, but connectivity is there. I'm having a hard time…
-
Applying selectors in queue's outbound messages using SolClient.js
Hi, I have checked the SolClient documentation link, however I couldn't identify any way of applying selectors while consuming queues messages. I undertsand that applying selectors can make the consumption slower. But in our use case, the queue is subscribing to 6 topics. And I want the consumers to read only the specific…
-
Tuning pre-fetch for load balancing in Python
Hi Team, I have built a system comprised of a number of workers, N, (or application processing engines) fed by a single non exclusive queue. Each job on the queue either takes between 20 second and a minute to complete or under 0.1 seconds (because the job on the queue requires no work). Ideally if there are 3 workers (so…
-
Applying ACL profile on Queue Subscription!
Hi There! i have a scenario to apply ACL policy for a JMS Subscriber, i would want them to subscribe only from specific Queue. Is there any possibility of achieving this with PubSub+ Broker? Currently i can see i can give exemptions on Topic in ACL profile but not Queues
-
Can durable queue be created in producer flow using solclientjs package in nodejs?
Does createDurableQueueDestination() method in solClientFactory creates durable queue if not exist in producer flow? var message = solace.SolclientFactory.createMessage(); message.setDestination(solace.SolclientFactory.createDurableQueueDestination(producer.queueName)); message.setBinaryAttachment(messageText);…
-
Introducing the "copy-message" command
Exciting news, Solace developers and administrators! You can now copy messages between queues! PubSub+ Event Broker version 10.0.0 has a new management command, copy-message, that lets a broker administrator copy a message from the replay log to a queue, or from one queue to another (like from a DMQ to a client’s queue).…
-
I'm not able to create a subscription topic under '#telemetry-trace' queue. How can I do it?
I'm using open-telemetry framework. I have created a queue named '#telemetry-trace'. Now I'm trying to create a subscription topic for that queue and I'm getting an error 'The #telemetry-trace queue may not be configured' Does anyone know how to solve this error? Thanks in Advance!
-
JMS destination showing as topic, eventhough the message is consumed from queue
Consuming messages from queue, but while analysing the received message, observed that the JMS destination is showing as the topic name which is subscribed to the queue. Can you explain why the received message's destination is not showing as queue instead the topic.
-
Consume a persistent Message from Queue or Subscription
After some studies, and proof of concept, I have a question about the consuming side, since the producer side is very clear to me. Let's say I need to save files using Solace Message Broker, so I have the following configuration for producer, topic, and queue: The producer sends a message with the Topic…
-
Solace DMQ (Dead message queue) best practices
Hi All, I am new to solace and recently we implemented an Azure connector to receive message from a solace queue to azure function. I wondering if there are any docos around handling dead letter messages in instance where azure function is down or there is a fault in processing etc. We have a DMQ ready that receives any…
-
Send a message to the Queue instead the Topic
After hours of studying in Solace Documentation, Youtube Channel and etc, I believe I've ended up with some points to check with you: Although we have some samples of sending a message to a queue, the best practice is to send a message to a topic. As I could see in the Spring Cloud Streams samples, this is the only way to…
-
Query regarding Topic Based Filtering of Payload
I have a Solace Topic Based Filtering related requirement in which we have a topic already established with the topic name: Dia/Tech/Mulesoft/Interlayer/PRC/PIOS/RSVD/RSVD/FromMSBQueue/Published/1/PRC/PIOS which is attached as a subscription to Queue in On-Premises : Dia.Azure.POC & Queue in Cloud Broker :…
-
[Demo & Live Coding] Replay to temporary queue
Tamimi and Rey show you how to use this feature.
-
[Demo & Live Coding] Delete all messages in a queue
Tamimi and Rey show you how to use the new feature.
-
SEMP API to delete the messages from the queue?
Hi Team, Is there any way or SEMP API available to delete the messages from a queue? Thanks Tejas
-
Is there a way to get a Queue Created Date in Solace?
Hello All, I would like to know if there is a way to get the queue created date via SEMP API's or any other means in Solace? Have tried with SEMP Over Message Bus & Monitoring SEMP API but it does not speak about when the queue was created. Thanks Tejas Chowsalkar
-
Backpressure / message delivery and the Python API
Hi, We have a non exclusive durable queue with several consumers (compute worker) who connect using the Python API. Each consumer runs the MessageHandler in a separate thread, essentially just filling up a buffer with messages, the messages are then consumed by the main thread in the compute worker and results sent out.…
-
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 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.
-
Library to Unsubscribe Topic from Queue
Hi Community, I am exploring Solace and its Use Cases. Using Solace Java API Library we can create a Queue and subscribe a Topic to the Queue. Using SEMP Java Client Library we can Create and Delete a Queue. Using SEMP REST API we can create and delete Queue , subscribe a Topic to Queue and can also unsubscribe a Topic…
-
Persistent receiver with subscription-specific listeners
Hi, Is it possible to have multiple topic-specific receivers and handlers to consume messages from a queue? Like: var receiver1 = messagingService.createPersistentMessageReceiverBuilder() .withMessageAutoAcknowledgement() .withSubscriptions(topicSet1) .build(queue) .start(); receiver1.receiveAsync((message) -> { //...…
-
How can we send bulk messages using nodejs?
I am sending around 100 messages with confirmed delivery. But Acknowledgement is delayed because of which I get OperationError: Guaranteed Message Window Closed after sending 50 messages. Is there a way to send more number of messages with guaranteed delivery? Code:…
