3,995 questions
0
votes
0
answers
19
views
Parallel sagas listening to the same channel are encountering a race condition
I'm attempting to develop an understanding of the Saga and Outbox patterns, and am working on development now. I'm using RabbitMQ and NestJS. I've got three services, Orders, Inventory, and Shipping. ...
- 73
0
votes
0
answers
12
views
BullMQ: Flow parent job's 'failed' event not triggered when child jobs fail
I'm implementing a job flow using BullMQ (latest version) with NestJS, and I've encountered an issue with error handling in flow jobs.
The setup
I have a parent flow job and multiple child jobs. The ...
- 1,415
1
vote
0
answers
73
views
Custom event not received in PeekMessageW [closed]
I have a loop that handles all of the window events using PeekMessage. It seems that, normally, the WM_SIZE message is not received by the PeekMessage function. So what I am trying to do is to ...
- 384
0
votes
0
answers
13
views
How to perform Geo-Replication in Apache Pulsar without creating duplicate messages?
I’m designing a multi-datacenter architecture using Apache Pulsar with geo-replication enabled.
Architecture Overview:
Apache Pulsar version: 4.0.2
Helm Chart version: pulsar-3.9.0
BookKeeper: 5 ...
0
votes
0
answers
13
views
Asynch integration approach between two ERP systems
We need to integrate two ERP systems which have to exchange many Entities (Items, Vendors, Prices ect.) and business Documents (Purchase orders, Sales orders, Warehouse transfer orders, ect.).
The ...
- 1
0
votes
1
answer
64
views
Understanding GCP Pub/Sub Sent Metric and Ack Metric With Dead Lettering
I am testing my Pub/Sub setup with dead lettering enabled. Inside my subscriber application, I have not added any ack logic so all messages will not be acked by my subscriber. I set the maximum ...
0
votes
2
answers
105
views
Discord Bot and a website communication, what should be the system design
I'm building a website that lets users add new items in their profiles. Users can also do the same using Discord bot's commands. In both cases the Discord bot sends a message New item added by @user ...
- 5,172
0
votes
0
answers
23
views
How to Handle APIs which takes more than 5 seconds in serverless applications
In One of the requriement we are hitting a third Party API which does some calculation at the backend and dependent on the various factors it can take time upto 5 seconds.
Usually serverless is to be ...
- 29
0
votes
1
answer
29
views
Send saga is not available in IoC anymore
I have a problem with Masstransit and the Saga feature.
I cannot explain the following errors:
Error: MassTransit.ReceiveTransport[0]
R-FAULT rabbitmq://localhost/monitoring-job-saga 489a0000-...
- 1
0
votes
0
answers
33
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,227
0
votes
0
answers
146
views
BullMQ Worker with rate limits and unique group processing
I’m working with BullMQ (v5+) and need to implement a worker to process messages for different chats, with the following requirements:
Rate Limit:
Each queue should have a rate limit of 1 job per 3 ...
- 31
1
vote
0
answers
33
views
Does SQS FIFO have any Issues with many MessageGroupIds?
I'm fairly new to working with FIFO SQS, and a question has emerged. Does using many different MessageGroupIds have any performance downsides or raise any concerns?
I'm working with an order queue and ...
0
votes
1
answer
100
views
When are Azure Storage Account Poison Queues Created?
We have Terraform that deploys our Azure Storage Accounts and associated Storage Account Queues.
I notice that there are also associated 'queuename-poison' queues when I view the deployed ...
- 30.5k
0
votes
0
answers
28
views
Can invariants span across multiple aggregate roots?
I've got a bit of a theoretical question surrounding DDD and aggregates. It really boils down to this: Yes, we all know that within an aggregate everything must stay consistent. But does that mean ...
- 73
0
votes
0
answers
82
views
Message Queue causing core dump when checking is message available
When I'm trying to check if new message is available in message queue, I'm getting core dump error.
I'm calling isDataAvailableInReceiveDataQueue method to check if data is available in message queue.
...
- 1,957