RabbitMQ is an AMQP broker, while ActiveMQ is a JMS one. I suggest you read the AMQP wikipedia article to get an idea of the concepts used in AMQP, which are different than the ones you’re familiar in JMS. One of the main difference is that in AMQP a producer sends to an exchange without … Read more
Unacknowledged messages are those which have been delivered across the network to a consumer but have not yet been ack’ed or rejected — but that consumer hasn’t yet closed the channel or connection over which it originally received them. Therefore the broker can’t figure out if the consumer is just taking a long time to … Read more
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
You can avoid the static classes and use Dependency Injection all the way through combined with: The use of IApplicationLifetime to start/stop the listener whenever the application starts/stops. The use of IServiceProvider to create instances of the message processors. First thing, let’s move the configuration to its own class that can be populated from the … 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
Remove the old installation of RabbitMQ to fix this problem. Here are steps to reinstall RabbitMQ. These commands are run as the root user: Stop RabbitMQ: rabbitmqctl stop Change /etc/hosts Change /etc/hostname Uninstall old RabbitMQ: dpkg -P rabbitmq-server Remove RabbitMQ’s database: rm -rf /var/lib/rabbitmq Find erlang’s process that is running rabbit: ps ax | grep … Read more
Finally I found the solution. These posts helped to figure this out. RabbitMQ on EC2 Consuming Tons of CPU and https://serverfault.com/questions/337982/how-do-i-restart-rabbitmq-after-switching-machines What happened was rabbitmq was holding on to all the results that were never freed to the point it became overloaded. I cleared all the stale data in /var/lib/rabbitmq/mnesia/rabbit/, restarted rabbit and it works … Read more