All Questions
Tagged with message-queue rabbitmq
675 questions
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
47
views
Why are messages lost after consumer recovery in RabbitMQ/MassTransit publisher-consumer setup?
In my MassTransit + RabbitMQ setup, I have a publisher that both sends and subscribes to events, and a separate consumer application. When the consumer is down and the publisher sends and processes an ...
- 90
0
votes
0
answers
60
views
How to define RabbitMQ queue using spring-cloud-streams without a listener
I need to set the exchange and queue for RabbitMQ in my Spring Boot application, the thing is, The application only acts as a producer, but I need to define de queue as well in the service.
steps that ...
- 306
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
1
vote
1
answer
256
views
How to implement RabbitMQ fanout type exchange in NestJS?
I'm currently working on integrating RabbitMQ into my monolithic NestJS application for real-time inventory management as part of my e-commerce app. I want to use a fanout type exchange to broadcast ...
- 109
0
votes
0
answers
17
views
Rabbit MQ Consumers to same message Context
This situation is happening to me and my team
we have a service that allows people to make investments, redemptions and position search by account, and all of it is fueled by Rabbit Mq but there is a ...
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
0
answers
29
views
IPC in node.js using RabbitMQ
I have multiple node.js modules running i want to send request to some particular module to trigger some of it's function and return back response. I want to use RabbitMQ for this, but not sure how to ...
0
votes
0
answers
52
views
Issue with Dynamically Configuring Streams in RabbitMQ with STOMP and WebSocket
I hope you are all well. I would like to share a problem I am facing in my messaging architecture.
Architecture:
Web clients: Connect to RabbitMQ using the STOMP protocol.
Exchange: Clients subscribe ...
0
votes
0
answers
24
views
nodejs rabbitmq - how can we wait that all messages are consumed before the API returns the response
I am very new to rabbitmq and I need to build some micro services.
So, I have two queues. The first application pushes a message to the queue-one which is an API and this message is consumed in the ...
1
vote
1
answer
150
views
Handling Long-Running Tasks and Subtasks with RabbitMQ and AWS Batch
Question:
I'm working on a system where I have a producer that initiates multiple tasks, each of which can take a significant amount of time to complete. Here's an overview of the system architecture:
...
- 75
0
votes
1
answer
177
views
How to Extract Queue Name, Priority, and Message ID from RabbitMQ Inbound Endpoint Messages in WSO2 MI 4.2?
I'm currently working on a project using WSO2 Micro Integrator (MI) 4.2, where I've set up an inbound endpoint to consume messages from RabbitMQ. In this scenario, I need to extract specific metadata ...
- 11
0
votes
1
answer
87
views
Is there any example or design of a queue system in microservices?
I just start to learn about microservices and message queue (rabbitmq) and I understand some exchanges as Direct, Topic,Fanout,Header,etc. But I do not clear about something like when should we close ...
0
votes
2
answers
58
views
How do I maintain the same internal host on RabbitMQ?
I am running RabbitMQ on a virtual machine of a local server (for development, testing, and staging environments). When there is an electrical power instability, the server ends up restarting, and ...
- 11
2
votes
1
answer
184
views
Is there a way to define a RabbitMQ consumer that keeps listening for a queue without blocking the program?
I am working on project, using RabbitMq in python. Initially an Admin Verify an order which is then published in a RabbitMq message queue 'verified_orders', I want to have a consumer that keeps ...
- 21