I have a rabbit queue with messages for consuming. I also have a listener that can fail. The queue is configured with a dead letter exchange (along with a dead letter queue). What I want is to see ...

Any idea why AWS Lambda functions are unable to publish messages to RabbitMQ using the amqp protocol? (I'm using the node.js runtime with the node amqplib runtime) When using the code from my loc...

I have some properties that I would like to read from previously set message headers. I did this: Delivery delivery = consumer.nextDelivery(); Map<String, Object> headers = delivery.getPro...

I have installed RabbitMQ to my Kubernetes Cluster via Google Cloud Platform's marketplace. I can connect to it fine in my other applications hosted in the Kubernetes Cluster, I can create queues ...

I was looking at Nestjs documentation to set up a microservice that listens to RabbitMQ messages. It's very straight forward when I have to listen to one queue. What if there are multiple queues th...

I was reading the documentation of django-channels for the first time today and found the following line Channels will take care of scheduling them and running them all in parallel. Does this mean,...

Using RabbitMQ as broker, I would like to copy all the messages from one queue to another queue for test/debug purpose. What's the simplest way via RabbitMQ web management console / cli? P.S. Unde...

I'm currently using the RabbitMQ (3.6.2-1) on Ubuntu(16.04) in production. Producers publish messages and consumers consume messages and everything works correctly but sometimes RabbitMQ doesn't re...

I installed rabbitmq service on the server and on my system. I want to use RPC pattern: var factory = new ConnectionFactory() { HostName = "158.2.14.42", Port = Protocols.DefaultProtocol.Defau...

We have a PHP app that forwards messages from RabbitMQ to connected devices down a WebSocket connection (PHP AMQP pecl extension v1.7.1 & RabbitMQ 3.6.6). Messages are consumed from an array o...

rabbit connection from console app : var factory = new ConnectionFactory() { HostName = Environment.GetEnvironmentVariable("RabbitMq/Host"), UserName = Environment.GetEnvironmentVariable("Rabb...

I have a web server written in Go that interacts with Rabbitmq and Mongodb. When I run all these servers on my machine without containers (rabbitmq url: amqp://guest:guest@localhost:5672) it works ...

Following a sudo apt-get install rabbitmq-server I'm hitting errors when the service attempts to start (also when using systemctl start): ● rabbitmq-server.service - RabbitMQ Messaging Server ...

I have a set up to send messages to durable queues from server (NodeJS) and the client (android app) listens to messages on their respective queues (each android device listens to its corresponding...

I have RabbitMQ installed and started. The service is running as well. However, when I try to open the management interface in firefox, I get this error: Firefox can't establish a connection to th...

I just switched from ForkPool to gevent with concurrency (5) as the pool method for Celery workers running in Kubernetes pods. After the switch I've been getting a non recoverable erro in the worke...

I start rabbitmq on docker with command: docker run -d --hostname my-rabbit --name rabbit-fox -p 5672:5672 -p 8090:15672 rabbitmq:3-management it runs fine and i can log into console, but later ...

I have installed rabbitmq using helm chart on a kubernetes cluster. The rabbitmq pod keeps restarting. On inspecting the pod logs I get the below error 2020-02-26 04:42:31.582 [warning] <0.314....

I am looking to be able to move messages between queues (manually) in Rabbit. For example: first-queue has messages ['a','b','c','d','e','f'] second-queue has messages ['x','y'] I want to be ab...

I tried out last 3 days with the below issue. Kindly help me to resolve the issue, >Error: Unexpected close at succeed (/usr/local/lib/node_modules/amqplib/lib/connection.js:259:13) at onOpenOk...

Being a new user of MassTransit and RabbitMQ I'm currently trying to make my ASP.NET core service to work with MassTransit. Taking this documentation section to configure MassTransit and ASP.NET C...

I am using the default configuration on latest RabbitMQ server (guest is admin) but I get the next exception when I run the RequestResponse sample. OperationInterruptedException: The AMQP operat...

I am using rabbitmq:3-management from https://hub.docker.com/_/rabbitmq/ however, it is missing a plugin that I need rabbitmq_delayed_message_exchange. How can I enable this plugin if it is not a...

This is the scenario - There are multiple app servers. Browser can connect via websocket to any app server. The app servers (consumers) are all listening on a particular queue. As soon as a web so...

I have installed sensu with chef community cookbook. However, sensu client fails to connect to server. Results in rabbitmq connection error with message timed out while attempting to connect Here ...