656 questions
0
votes
0
answers
52
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
Best practices
1
vote
3
replies
117
views
.NET - Messaging - Where to place shared contracts
I have a question about sharing contracts between services using a message broker (more specifically, Azure Service Bus). I searched for it in various articles and asked a chatbot, but I didn't get a ...
- 231
0
votes
1
answer
123
views
How to publish once to a topic and route them to different queues based on the topic in the Solace broker?
I want to publish a sale of a product. I just wanted to publish once to a topic like sale/124 where each number represents an id of a store. Then each queue connected to that store only had to ...
- 11
0
votes
0
answers
110
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
0
votes
0
answers
58
views
How to dynamically extend the holding time of a message for the message consumer in RabbitMQ?
Simply put, I want to implement the same function of ServiceBusReceiver.RenewMessageLockAsync of Azure Service Bus queue in RabbitMQ. This function lets the message consumer "extend" the &...
- 2,317
1
vote
1
answer
248
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
202
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
-1
votes
1
answer
74
views
Should i write minimal or big ones with data duplication in microservices
Consider i have these two models that live in a different microservices. I can write them in two ways:
public class Order
{
public Guid Id { get; set; }
public Guid ItemId { get; set; } ...
0
votes
0
answers
56
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 ...
0
votes
0
answers
181
views
VerneMQ handling client disconnections in a clustered environment
VerneMQ broker with 3 nodes A,B and C is deployed in Kubernetes with clustering enabled. Assume that a client x is connected to Node B. A request to disconnect client x is sent to the broker and the ...
- 139
1
vote
0
answers
45
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
0
votes
1
answer
200
views
Cannot connect to MQTT broker via SmallRye Reactive Messanging MQTT connector in Quarkus
I am trying to connect MQTT connector to my broker.
Broker is listening on ws://localhost:1234
I am using a Quarkus as my backend framework. The configuration for my MQTT connector is set as:
# ...
- 99
8
votes
2
answers
5k
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
2
answers
654
views
SQL queue doesn't start activation procedure SQL Server
SQL Server 2019
I'm trying to start stored procedures from a trigger (so that the trigger stays lean) to process data in some production facility. Working with queues/messages etc is new to me
I've ...
- 13
0
votes
0
answers
67
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