658 questions
0
votes
0
answers
33
views
Message queue where each key is processed by only one consumer at a time, but other messages for the same key can be assigned to other consumers
I'm building a distributed system that processes messages from hundreds of thousands of sensors, each identified by a sensor_id.
I need to guarantee:
Strict ordering per sensor_id
No two consumers ...
- 1,510
0
votes
0
answers
64
views
celery worker not consuming tasks from rabbitMQ queue
I have a queue in RabbitMQ broker called queue-ktm of type quorum. There are tasks pushed to this queue and available.
I run a celery worker to consume from this queue with following configuration:
...
- 4,161
0
votes
0
answers
90
views
Unable to Receive MQTT Messages Inside Docker Container on Ubuntu Server
I have a code that works fine on my Ubuntu server, but when I run it inside a container, I don’t receive any messages. It seems like the container doesn’t have access to the MQTT broker.
However, I ...
- 586
1
vote
1
answer
158
views
Kafka and hotspots in a partition
I am new to Kafka and I understand that there is only guarantee of message order within one partition and not across partitions.
What I am not sure is if this can create scalability issues e.g. in ...
- 311
0
votes
1
answer
131
views
WebSocket with Kafka/Active Mq/Rabbit Mq | Spring
My On-Prem application details:
Frontend - Reactjs deployed in 4 VMs [a,b,c,d]
Backend - Spring microservices[Stateless] deployed in 4 VMs [w,x,y,z]]
Database - Sql server
Load Balancer - F5
CDN - ...
- 61
0
votes
0
answers
47
views
Message sent to RabbitMQ exchange is not passed to the bound queue
I'm new to message brokers and feel quite confused. The task is to send changes from PostgreSQL table to a RabbitMQ as a no-code solution. The instrument chosen is pg-bifrost. I took a look at the ...
1
vote
0
answers
40
views
After consuming a message from the RabbitMQ queue, the database query returned an unexpected data
I have create a channel and then sent a message to a queue using channel.sendToQueue() method and I have also create a channel in other module and try to consume messages from the queue ...
- 195
7
votes
2
answers
4k
views
Inbox pattern and outbox pattern
I don't see the difference between the Inbox pattern and the Outbox pattern.
the Inbox pattern saves messages in a database. The Outbox pattern too, so what is the difference?
0
votes
0
answers
63
views
Problem with C# submitting file to IBM MQ Broker
I am trying to submit a Soap XML payload file to our IBM MQ Broker, which will then pass the file on to the destination application. I don't have direct connectivity to the destination app, so I'm ...
- 323
2
votes
2
answers
190
views
MQTT handleMessage Function Not Invoked Despite Subscription
I'm working on a Go application that subscribes to an MQTT topic and processes incoming messages using a handleMessage function. However, I'm encountering an issue where the handleMessage function is ...
- 141
1
vote
1
answer
989
views
At what point to create queues in messages broker?
At what point is it customary to create queues in message brokers? For example, I have a RabbitMQ in my application, and accordingly I need to create queues before launching it.
I'm still thinking ...
- 113
1
vote
1
answer
731
views
RabbitMQ BrokerUnreachableException (.net 4.8 vs .NET 8.0) (doesn't work/works)
I am trying to connect to a localhost RabbitMQ server on my machine and keep getting the error.
Error:
RabbitMQ.Client.Exceptions.BrokerUnreachableException: 'None of the specified endpoints were ...
- 1,258
0
votes
1
answer
642
views
Cannot see Pub/Sub message on ActiveMQ Artemis console
I'm studying JMS using the book Spring Boot Messaging by Felipe Gutierrez (2017).
It illustrates several patterns about message driven programming but, arriving at brokers, it explain Java / Spring ...
- 777
1
vote
2
answers
2k
views
How to subscribe to multiple topics (at least 2) and republish the message recieved to a single topic with Mosquitto MQTT using linux shell comands
Iam trying to figure out a way to subscribe to multiple topics, and then after receiving a message the function should publish it to a different broker depending on the topic.
I've thought of ...
1
vote
1
answer
2k
views
How Does Celery AsyncResult Function Know Which Broker or Backend to Query?
This is how I am sending a task to the celery workers and capturing the resulting task id. The app variable, i.e. the celery app, has the redis broker and backend url set as part of its properties. ...
- 1,730
0
votes
0
answers
328
views
I'm not able to see messages on queue on RabbitMQ managment portal with MQTT over WebSocket and they are not stored in a queue
Following the RabbitMQ documentation I'm trying to subscribe and receive messages in the browser from the /topic/test topic. Meanwhile to send them to RabbitMQ I'm using a program called mqtt-explorer....
- 1
0
votes
1
answer
183
views
Is it possible to delete a queue or topic from ActiveMQ Classic from a client application?
We are using ActiveMQ Classic 5.15.15. I believe when the broker receives a new message it creates the corresponding queue or topic.
Is it possible to completely delete (not purge!) a topic or a queue?...
- 27
1
vote
0
answers
505
views
"Stream connection lost: ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None)"
I am trying to connect rabbitmq to python and run a basic hello world..!! program but the connection show this error:
"Stream connection lost: ConnectionResetError(10054, 'An existing
connection ...
- 125
0
votes
1
answer
257
views
what is difference between AMQP connector and JMS connector in mule?
I'm bit confused between AMQP and JMS when to use which connecter ? like if i have Rabbit MQ then go for AMQP and Active MA then JMS.
How can i identify the connecter based based on various customer/...
- 424
0
votes
1
answer
922
views
Azure Service Bus handler in Azure Function
I am straggling with that issue couple days and need help.
I send message to azure subscription in business layer using that code:
var sender = _serviceBusService.GetSender("event-send");
...
- 47
0
votes
0
answers
230
views
RabbitMQ - How to achieve FIFO in priority queue?
Below code to add message to priority queue
var priorityArgs = new Dictionary<String, Object>();
priorityArgs.Add("x-max-priority", 10);
channel.QueueDeclare(...
- 913
0
votes
1
answer
273
views
Check if binding exists
I would like to check if a certain binding exists on a queue or an exchange in a Spring application. I can only find information about checking if an exchange exists.
or a queue: RabbitAdmin.java
I'm ...
- 817
0
votes
0
answers
99
views
Which message brokers support one to one mapping between a key value and the consumer
I am currently trying to choose a message queue in my backend system and for a use case I would need to do the following
Producer services will publish messages that involve a field named foo
I want ...
0
votes
1
answer
747
views
Not able to get result set from stored procedure in ESQL?
I am calling external stored procedure from esql., where input is also clob and output also clob.
i have to send input and and get response from Oracle DB Stored procedure.
but im getting error as ...
0
votes
0
answers
21
views
How to automate Message Broker?
Message Broker is a third party app in my project, and deployed on edge browser.
During login, it is asking for authentication through Microsoft Authenticator.
How to start automate.
I am looking for ...
