-
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) -> { //...…
-
Topic dispatching with guaranteed delivery using JCSMP
Hi there, The article here explains how one can have custom callback to handle guaranteed messages received with matching topics thru flows bound to queues using Java RTO. Is there something similar for the JCSMP API, or another way that we can achieve something like that? On a related note, there's normally only be one…
-
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:…
-
What is the best way to get the actual queue message count ?
I am using currently Jcsmp and sure i can use queue browser to fetch all data and check collection size but there should be an easier way to check queue size without fetching all data. So i find this one: https://solace.community/discussion/398/how-to-check-the-size-of-a-message-queue But when i run towards my docker image…
-
Purge or Delete Queue message via C#.net
We have few application services currently using Message Queue and currently transitioning to use Solace Messaging. In .Net Message Queue, it has a feature the Purge all the Messages. These application services require to Purge all messages when it is starting. I do aware Solace Application do have this in Queues -> Queue…
-
TTL - Message Expiry check on the queue..
If TTL on a message is set to 180secs (say), wondering when the expiry is checked and removal of expired events occur? Just curious how the following scenarios are handled: a) If DMQ is enabled, the dequeue from current queue and enqueue on the DMQ has to occur at the exact time when the message expired, right? b) If no…
-
Prevent Queue subscribing application to receive another message until ACK is sent
Hi there, I have a consuming application using the solace .NET client API which binds to an exclusive queue. May aim is to process messages in order without any loss. Suppose I have the following messages on the Queue: msg1, msg2, and msg3. Let's say I have received msg1 and am processing it on the FlowMessageHandler in my…
-
In Spring cloud , i would like to print logs which will tell to which queue application is connected
Hi, I am working on spring-cloud-solace. In application i need logger to track which queue application is connected to. Could you pls help
-
Queue to Topic Mapping List For Solace VPN
We use Solace queue to topic subscription mapping extensively in our Solace Ecosystem and most of time Application is not aware about underling queue and whenever application face any issue they provide VPN name and topic to administration team to check ! Now from here main pain point begin, because we have multiple…
-
measure size of queued messages - how identify how many messages >10k shipped ?
measure size of queued messages. How identify how many messages >10k shipped ? i only see the queue but not the size of message. show queue ...
-
Levels for naming topic/queue names
Is it always required to provide pattern of all 4 levels when we create a solace topic?
-
Queue: It's a Noun... It's a Verb... It's Both (2 of 2)
Queue as a noun, represents a list of objects, commands, etc., stored in a retrievable, definite order in the order of insertion. Queue as a verb, represents an operation to (re)arrange items from the set of operations such as dequeue, browse, replicate, empty, etc available on a queue. Solace Queues are created and…