Scheduling Basic Consume in RabbitMQ

Question

I am using RabbitMQ from last month successfully.Messages are read from queue using BasicConsume feature of RabbitMQ.The messages published to queue is immediately consumed by the corresponding consumer. Now i created a new queue DelayedMsg,The messages published to this queue has to be read only after 5 min delay.What should i do?

Answer 1

Add a current timestamp value to the message while publishing message to the main queue from publisher / sender. Say example, 'published_on' => 1476424186.

At the consumer side, first check the time difference of current timestamp and published_on.

If the difference found to be less than 5 minutes, then send your message in another queue ( a DLX queue ) with setting expiration time.( use 'expiration' property of amqp message )

This expiration value should be ( current timestamp - published_on ) and it should be in milliseconds.

The message will gets expired in the DLX queue on exact 5 min.

Make sure 'x-dead-letter-exchange' should be your main queue exchange and is bounded with the dlx queue so that when the message gets expired, it will automatically gets queued up back into the main queue. see Dead Letter Exchange for more details.

So, consumer now get the message back after 5 min, process it normally, since its current timestamp and published_on difference will be greater than 5 min.