Questions tagged [rabbitmq]

0 votes
0 replies
Unable to broadcast message using celery
I'm trying to use celery's build in support for broadcast routing using Broadcast and using rabbitmq as the broker. I have been able to successfu...
1 votes
0 replies
RabbitMQ - Is there a test ack system to cope with a redelivery?
In RabbitMQ, when setup with acks enabled... If a consumer fails its heartbeat and rabbit re-queues a piece of work that the consumer already h...
asked 4 months ago
0 votes
1 replies
How to read RabbitMQ queue messages one by one
I have a requirement where I need to read the messages of DLQ and do appropriate action based on that. Earlier, below code snippet was working fi...
asked 4 months ago
-2 votes
0 replies
how to send and handle message in 2 deiffrent symfony application [closed]
is it possible to send and receive in 2 different Symfony application by rabbitmq !? for example application 1 send an message and application 2...
asked 4 months ago
0 votes
1 replies
RabbitMQ consumer in ASP.NET Core application whith out the web request
Summary i do how it resolved in Setup RabbitMQ consumer in ASP.NET Core application but my Rabbit consumer online if i do web request, if i start...
asked 4 months ago
0 votes
0 replies
Why is my RabbitMQ message impossible to serialize using Apache Beam?
I'm trying to read a RabbitMQ queue using Apache Beam. I've written some transformation code to have messages written to Kafka. I've even tested...
asked 4 months ago
0 votes
2 replies
MassTransit / RabbitMQ - why so many messages get skipped?
I'm working with 2 .NET Core console applications in a producer/consumer scenario with MassTransit/RabbitMQ. I need to ensure that even if NO co...
asked 4 months ago
0 votes
0 replies
celery:why is it useful when I delete the item “search localdomain” in /etc/resolv.conf
when I use " celery -A tasks worker -l info " , then the worker node occurs following : [2019-04-26 20:27:00,290: ERROR/MainProcess] consumer: C...
asked 4 months ago
0 votes
1 replies
Get messages by property or header in RabbitMQ
I'm new in to RabbitMQ and I've faced a problem. I'm trying to get messages from queue by API method. I've made that by now I want to get message...
asked 4 months ago
0 votes
1 replies
Resiliently processing messages from RabbitMQ
I'm not sure how to resiliently handle RabbitMQ messages in the event of an intermittent outage. I subscribe in a windows service, read the mess...
asked 4 months ago
0 votes
1 replies
RabbitMQ Multiple Unique Consumers on Windows Service
I've searched StackOverflow and I don't think the other issues around multiple consumers match what I am trying. I have a Windows service that s...
asked 4 months ago
0 votes
0 replies
Adding Queues to Rabbitmq and workers to the queues in Celery
Trying to execute about 66 python scripts that do some data manipulation tasks. Three scripts take an awful amount of time to execute as they are...
asked 4 months ago
1 votes
0 replies
How to access the values of a list that is inside tasks.py via views.py while the list is filling and the task is not finished yet?
I have a simple function in views.py and I need to call a task in this function to do something and put the result in a list. So, I need to read...
0 votes
2 replies
How to use header exchange to send and recieve java objects as messages from queues in rabbitmq
I am trying to use header exchange in rabbitmq to produce and consume messages. When i am trying to produce the message i have to convert the mes...
asked 4 months ago
1 votes
1 replies
Data consistency between Microservices with RabbitMq
I'm attempting to setup a practical Microservice demo for a few simple internal systems that deal with order management at my company, however I...
asked 4 months ago
0 votes
0 replies
python error 104 Connection reset by peer using rabbitmq SSL
I'm trying to configure SSL in the connection between rabbitmq and Pika client (in python 2.7), therefore I have followed the tutorial in https:/...
asked 4 months ago
0 votes
1 replies
How to gracefully stop consuming messages with @RabbitListener
Is there a way to gracefully stop a ListenerContainer, and its associated Consumers. What I'm trying to achieve. Stop consuming messages. Grac...
2 votes
2 replies
How to consume 100 messages without ack, then do work and then acknowledge them?
I'm consuming messages from a rabbitmq with spring amqp. I'm consuming one message at a time and its pretty slow cause I save it to DB. So openi...
asked 4 months ago
0 votes
0 replies
Re-delivering non acknowledged message to the same consumer without closing channel or broker restart
Consider the following scenario: A message is put on a queue. The queue is declared to be durable. A single consumer gets the message from the...
asked 4 months ago
0 votes
1 replies
Unable to connect to RabbitMQ started with Docker in a C# program (with RabbitMQ.Client)
I started a RabbitMQ container following the article: https://docs.docker.com/samples/library/rabbitmq using the image including the management t...
asked 4 months ago
1 votes
0 replies
CQRS and Event Sourcing Guide
I want to create a CQRS and Event Sourcing architecture that is very cheap and very flexible and very uncomplicated. I want to make sure that ev...
3 votes
3 replies
Failing ParseFrom messages in java from C++
I have a question/problem. I'm sending messages from C++ to Java (Play framework) using RabbitMq. So, in C++ side I used SerializeToString funct...
asked 4 months ago
0 votes
0 replies
How to interact with Visual Studio debugger stdin when debugging a .NET docker compose application?
I have a simple .NET C# console project consuming RabbitMQ with MassTransit: using System; using MassTransit; namespace ConsoleApp1 { publi...
asked 4 months ago
0 votes
0 replies
Cluster formation on single machine, starting second node crashes because port in use
On my desktop I'm trying to create a RabbitMQ cluster. After installing RabbitMQ server v3.7.14 (and Erlang v21.3), the first rabbit@localhost no...
asked 4 months ago
0 votes
0 replies
Make Locust Wait Between Task Runs
I am using Locust to push messages into a RabbitMQ queue. I'm able to do this easily using the RabbitMQ sample from the locust.io-demo repository...
asked 4 months ago