The answers on this question are out-of-date. As of RabbitMQ 3.5.0, there is now in-core support for AMQP standard per-message priorities. The documentation has all the gory details, but in short: You need to define the queue’s priority range at the time the queue is created; Messages without a priority set get a priority of … Read more
Rabbitmq is set to start automatically after it’s installed. I don’t think it is configured run with the service command. To see the status of rabbitmq sudo rabbitmqctl status To stop the rabbitmq sudo rabbitmqctl stop (Try the status command again to see that it’s stopped). To start it again, the recommended method is sudo … Read more
In Microservices architecture you have two ways to communicate between the microservices: Synchronous – that is, each service calls directly the other microservice , which results in dependency between the services Asynchronous – you have some central hub (or message queue) where you place all requests between the microservices and the corresponding service takes the … Read more
Close the channel that the unacked messages reside on, which will nack them back into the queue, then call purge.
There is a “Get Messages” section for each queue in the management API. However this causes the message to be consumed and hence is a destructive action. We can re-queue this message to the queue only at the expense of sacrificing the ordering of messages [for rabbitmq versions < 2.7.0]. A more viable alternative would … Read more
Well, it is true that exclusive queues will auto-delete when the consumer disconnects (see the documentation pasted below). However, there are cases when you want queues to be non-exclusive, yet still auto-delete (for example, if I want to add another consumer). exclusive Exclusive queues may only be accessed by the current connection, and are deleted … Read more
Gentilissimo Signore was kind enough to answer my question on Twitter. The problem is that if your dead letter exchange is setup as DIRECT you must specify a dead letter routing key. If you just want all your NACKed message to go into a dead letter bucket for later investigation (as I do) then your … Read more
Assuming both models are being considered to be implemented using one broker running, there’s little difference that I can see. Option 2 seems more common in the real world for solving this kind of routing problem (at least in my anecdotal experience) and it’s exactly the challenge that Topic Exchanges exist to solve. The only … Read more
The immediate and mandatory fields are part of the AMQP specification, and are also covered in the RabbitMQ FAQ to clarify how its implementers interpreted their meaning: Mandatory This flag tells the server how to react if a message cannot be routed to a queue. Specifically, if mandatory is set and after running the bindings … Read more
It turns out that it is related to permissions. Somehow my rabbitmq server was started with user ‘rabbitmq’ (which is strange), so that I had to do sudo -u rabbitmq rabbitmqctl stop