-
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?
-
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 ==…
-
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…
-
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