Make sure that a qpidd broker is running:

$ ps -eaf | grep qpidd

If a broker is running, you should see the qpidd process in the output of the above command. If no broker is running, see the instructions in Chapter 3, Installing MRG Messaging.

In the direct directory, build the examples using make.

$ make

Declare a message queue and bind it to an exchange by running declare_queues, as follows:

$ ./declare_queues

This program has no output. After this program has been run, all messages sent to the amq.direct exchange using the routing key “routing_key” are sent to the queue named “message_queue”.

Publish a series of messages to the amq.direct exchange by running direct_producer, as follows:

$ ./direct_producer

This program has no output; the messages are routed to the message queue, as instructed by the binding.

Read the messages from the message queue using direct_consumer or listener, as follows:

$ ./direct_consumer

or

$ ./listener

You should see the following output:

Message: Message 0
Message: Message 1
Message: Message 2
Message: Message 3
Message: Message 4
Message: Message 5
Message: Message 6
Message: Message 7
Message: Message 8
Message: Message 9
Message: That's all, folks!
Shutting down listener for message_queue