RabbitMQ Cookbook

Consuming messages

In this recipe we are closing the loop; we have already seen how to send messages to RabbitMQ—or to any AMQP broker—and now we are ready to learn how to retrieve them.

You can find the source code of the recipe at Chapter01/Recipe03/src/rmqexample/nonblocking.

Getting ready

To use this recipe we need to set up the Java development environment as indicated in the introduction.

How to do it…

In order to consume the messages sent as seen in the previous recipe, perform the following steps:

1. Declare the queue where we want to consume the messages from:

   String myQueue="myFirstQueue";
   channel.queueDeclare(myQueue, true, false, false, null);

2. Define a specialized consumer class inherited from DefaultConsumer:

   public class ActualConsumer extends ...