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 ...

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 trying to set up RabbitMQ to route messages through a Dead Letter Exchange based on the death reason (either "x-death.reason" or "x-first-death-reason" would do). My unders...

I am able to create a fanout exchange using the Publish/Subscribe RabbitMQ Java tutorial, and any connected consumer will receive a copy of a message. Instead of declaring an exchange and binding d...

While using Clusters in Rabbit MQ, I was planning to use the Competing Subscriber pattern. Producer : 1 Exchange : 1 direct Queue : 1 Consumers : n (multiple) listening to the same queue. Now if...

I'm publishing RabbitMQ messages using Bunny (Ruby) like this: x.publish("Message !"+n.to_s, :routing_key => 'mychannel') and subscribing like this: ch = conn.create_channel x = ch.topic('f...

I have set up RabbitMQ server on my dev machine using this docker image. I have used below command to setup my container docker run -d --name my-rabbit -p 5672:15672 rabbitmq:3-management Below...

I'm using rabbitmq to handle messages between my databases for an enterprise application I work on. As part of the process, I'm trying to help automate the setup of the servers (e.g. script it). In...

We've got an application which will be using RabbitMQ and have several different queues for passing messages between tiers. Initially, I was planning to use multiple direct exchanges, with one for...

I'd like to implement a RabbitMQ topology similar to Option 3 here, except for some differences: The new topology should handle a few 1000 messages per day. And it shall have two exchanges: one ...

We are building a solution in which we are publishing message to a time-out queue. After TTL expiry messages are pushed to main queue for re-processing. We are setting up counter value so that me...

In my project I saw that there is a chance of acknowledging the same delivery tag twice. When this happens, the consumer gets unbound from the queue and no further messages come to the consumer (Ob...

What are the allowed types of messages (strings, bytes, integers, etc.)? What is the maximum size of a message? What is the maximum number of queues and exchanges?

Why do we need routing key to route messages from exchange to queue? Can't we simply use the queue name to route the message? Also, in case of publishing to multiple queues, we can use multiple que...

I've been looking at MassTransit for a couple of weeks now and I'm curious about the possibilities. However, I don't seem to be able to get the concepts quite right. Expected behaviour I wanted ...

I am using RabbitMQ 3.0.3 version. The service was working fine for last 4-5 years. Recently some updates patches were installed on the server and the Service stopped responding. This is what is ha...

I`ve been reading about the principles of AMQP messaging confirms. (https://www.rabbitmq.com/confirms.html). Really helpful and wel written article but one particular thing about consumer aknowledg...

Rabbitmq documentation says that we need to do some configuration before we use it on production. One of the configuration is about maximum open file number (which is an OS parameter). Rabbitmq se...

rabbitmqctl have the subcommand list_exchanges to list all the exchanges. How can I create an exchange using rabbitmqctl, as I didn't see the add_exchanges subcommands?

I have an exchange with a vhost, user, etc from that exchange I bind different queues. The exchange and the queues are in the same vhost. Now I want to create a different vhost for a different queu...

TLDR; In the context of a topic exchange and queues created on the fly by the consumers, how to have a message redelivered / the producer notified when no consumer consumes the message? I have the...

I am using spring-boot-starter-amqp 1.4.2.Producer and consumer working fine but sometimes the incoming JSON messages have an incorrect syntax. This results in the following (correct) exception: o...

From spring boot tutorial: https://spring.io/guides/gs/messaging-rabbitmq/ They give an example of creating 1 queue and 1 queue only, but, what if I want to be able to create more then 1 queue? ho...

(Picking up from a Github Issue) We use RabbitMQ's consistent hash exchange which is useful to shard routing keys from an exchange to multiple queues. We use the queues to dish out work to worker...

It seems like the worker pattern, fanout, and filtered topics can all be implemented with topic exchanges. Why would I ever use a direct or fanout exchange instead? We would like to codify common ...