-
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…
-
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 ==…
-
Golang Parallel For One Consumer?
How can I increase the number of connections for a consumer using pubsubplus-go-client? We pass a callback to ReceiveAsync for a consumer via PersistentMessageReceiver, but only one message is processed at a time.
-
Cleanup of Unused Queues
In an use-case like an mqtt client connects with CleanStart: No and Durable: Yes, the queue will be created and msgs are consumed as per the subscriptions. But when we restart the client, with a different session name will lead to creation of new queue. Now, both the old and new queues will have the same subscriptions.…
-
Binary to ASCII
Hi @marc @Aaron How do I convert the data received from queue(lvq) to ASCII or human readable format?
-
Queue with random order?
We aim to have a queue without order. The motivation behind this is that younger events update older events, and the updating process is relatively 'expensive'. However, if younger events arrive first, older events are simply discarded. How can we enable this?
-
How to make Queue browser to stop listening when no more message are in queue?
Context: I am using the Java API for browsing messages. I have my code looking like this: MessagingService messagingService = createMessagingService(clientUser, clientPass); Queue queue = Queue.durableExclusiveQueue(queueToBrowse); MessageQueueBrowser browser; if (selector == null || selector.isEmpty()) { browser =…
-
Using selectors in exclusive queue
Hi I'm trying to use exclusive queue with many consumers with different selectors. For some reason after starting application and providing consumers only first one stays active. Used library is JCSMP. var flowProps = new ConsumerFlowProperties(); flowProps.setEndpoint(queue);…
-
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…
-
Receiving Error Response (503) Max clients exceeded for queue
Definition of exclusive queues: exclusive specifies that only one consumer can receive a message at any one time, while additional consumers may be connected as standby. That is, only one Flow can be active. Only the first consumer to bind can receive messages. If the first consumer disconnects, the second consumer…
-
Queue Authorizations
Dear All, When I check the queue authorizations(permissions), it looks like it's based on either you're being an owner or not and there is only one owner if I am mistaken. Is there a way to assign this ownership to multiple users-consumers so that only "these" can do the same activities, instead of only one user.
-
Javascript API > Return a specific range of messages from a queue without consuming them.
I have a use case where I'd like to browse a specific subset of messages from a queue. Example: 100 messages on a queue. We'd like to browse messages 20 to 30 without returning all 100 messages. I don't want to consume these messages so I think a QueueBrowser would suit, however, I can't see support for this in the…
-
How to scale services listening to multiple exclusive queues.
I have an application/service which listens to 10 exclusive queues(let's say we have 10 apache camel routes, each route is listening to one queue) where we are receiving the ordered messages in each queue. I want to scale this service upto 10 pods/instances incrementally. But now I want to have only 2 pods, each listening…
-
How to consume messages synchronously from a solace "Queue" via Spring boot application?
Hi Team I am trying to develop an application where we connect to a Queue ( which is subscribing to multiple topics) and read message synchronously and make sure the next message is consumed only after current message is acknowledged. I tried reading resources provided by solace documentation and found snippet available…
-
How to keep the queue consumer flow open?
Hi everyone, I have actually a bunch of questions, hopefully it's okay to ask here :) How to keep the queue consumer flow open? Example Consumer provided here (https://tutorials.solace.dev/dotnet/persistence-with-queues/) gets messages only currently on the queue and closes immediately after that. How to keep the flow open…
-
.NET - Enforcing Queue to Respect Message Priority
Hello everyone, I am trying to implement a simple PoC solution to check whether Solace PubSub+ will be appropriate for my company. All went fine to the moment I wanted to use priority messaging. I would like to 1. create a queue from .NET 2. assign Priority to messages 3. enforce the queue to respect message priority…
-
How to export queue configuration with SEMP API
I'm building a process to integrate Solace with CI/CD, where we need to export the queues from Dev to UAT as part of the deployment process. Basically developer create the queues in DEV using UI and then its moved to upper envs with automation. I could not find a way to export specific queues configurations using SEMP,…
-
Is there way to bulk delete the queues
I need to delete multiple queue at one go, current SEMP api supports deleting single queue at time. Is there anyway we can delete multiple queues? Current SEMP delete queue api details
-
Regarding Connectivity status, Session status and Consumer status
We are a consumer of couple of Solace queues. We are consuming messages from (1) Kafka Connect framework using Solace PubSub Plus Source Connector, (2) Custom developed Spring Boot Application using Solace JMS API. Case #1: issues with Solace PubSub Plus Source Connector Sometimes we found that the connector is not listed…
-
Message redelivery on Exception
Hi, I'm evaluating a move to Solace by playing with a PubSub+ Cloud free instance. I'm not sure to understand the message redelivery policy. My implementation is based on spring-jms backed by qpid amqp. I was expecting that an exception thrown from a @JmsListener annotated method would reject the message which then would…
-
Partitioned Queues are now Generally Available with 10.4.0
Solace Community, I'm proud to announce that Partitioned Queues are now generally available for all in today's release of 10.4.0! Partitioned Queues are included in the PubSub+ broker software at no extra charge and are supported by our most recent releases of Solace JCSMP, JMS, CCSMP, Python, Golang, .NET, and JS APIs as…
-
Get all messages from a queue
Dear Team, I have a requirement to retrieve all the messages from a queue at a given point of time. I believe On-demand JMS or Consume operations can only read one message per request. Do we have any parameter to configure in JMS or Consume operation in Mulesoft Soalce connector. Can we achieve this via SEMP apis? I would…
-
Find out Consumers of Particular topic
Hi All, How do you find out list of consumers of a particular topic? Would we be able to search who all consuming the given topic? Let us say, I have below queues subcritpion Q1 - hello/first Q2 - hello/second Q3 - hello/first Q4 - hello/first How do you find out the list of Queues who are consuming topics hello/first?
-
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…