All Questions
Tagged with message-queue queue
253 questions
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
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 ...
-1
votes
1
answer
26
views
Any HTTP/HTTPs supported Messaging or Queuing system available?
Friends,
I am looking for Messaging/Queuing service, preferably opensource that supports Queuing-Dequeuing over HTTP(its a must). I know there are a lot of Cloud based services(AWS SQS, Azure EventHub)...
- 307
0
votes
0
answers
31
views
Making Queue class singleton is incorrect?
QueueFactory
/**
* QueueFactory.ts
*
/
/**
* `QueueType` is an enum representing the different types of queues that can be created using the `QueueFactory`.
*/
export enum QueueType {
RABBITMQ =...
- 101
0
votes
0
answers
104
views
.NET database-backed queues
I'm creating an API in .NET 8 for small uses and I need to implement 3 or 4 queues for long processing that don't depend on other systems besides its own database, like RabbitMQ.
I've only found the &...
- 172
0
votes
1
answer
31
views
How consume messages indefinitely in RabbitMQ using amqpblig?
I did a native a simple approach using ampqlib following RabbitMQ official documentation to consume messages indefinitely:
After a couple days suffering, my manager explained it was a really silly ...
- 5,752
0
votes
1
answer
410
views
How producer-consumer logic works in Laravel?
For example I want to create two separate projects that should communicate through some queue (rabbitmq for instance).
Do I understand correctly that I just have to create some job in producer project ...
- 3
1
vote
0
answers
407
views
How to implement queuing for incoming API Requests in Python based FastAPI Web Application
We have a FastAPI Application that recieves some data related to the remote servers in the form of API Calls. We are looking forward to make this a production grade application. For This we need to ...
- 11
0
votes
1
answer
701
views
RabbitMQ: Queue -> Shovel -> Stream - How to correctly configure for Stream message format
On one server, I want a Queue (buffer) and when there is a connection to the other server, it should Shovel its messages to the Stream there. I want to access the Stream with a Python client and the ...
- 82
0
votes
0
answers
155
views
Manage pressure when polling SQS
Note: this is about adaptive scaling SQS poller/subscriber, but I tried to present it in slightly more abstract terms, just a backpressure managment and a mediator.
In code, I skipped all lock, ...
- 1,210
0
votes
1
answer
80
views
Manage ID for tasks not processed yet in queue
I'm looking for tutorials/articles that explain how to maintain ID for items in queue that were not processed yet.
I am looking for a few tutorials to get more perspectives and be exposed to more ...
- 826
1
vote
1
answer
322
views
MassTransit multiple Consumers
I Have one Consumer-A, and i want to create multimple endpoints witj this consumer. For companies that can be added at runtime. Each company should have its own queue. Is it possible to do with ...
- 119
-1
votes
2
answers
1k
views
Implementing a queue of function calls that runs in parallel to the rest of the code
I'm currently building a program in JavaScript that is making requests of the google sheets API based on activity occurring in a Discord Server (messaging app). However, I've been running into the API ...
1
vote
0
answers
1k
views
Are delayed messages in Redis reliable?
I have an architecture solution that relies on the delayed messages.
In short:
There are many clients (mostly mobile devices running android or ios) that can process a given job.
I am creating a job ...
- 2,253
1
vote
1
answer
68
views
My code receives the message from the queue multiple time, I want to receive it only one time. How can I do it?
I am new, so my question is relatively easy, I guess.
I am using Websphere Application Server platform and default JMS provider to send and receive message from queue. This is how my app looks like:
...
- 13