The following diagram provides an overview of the scenario that we will implement:
The sender will send a message to the default exchange with a routing key that matches the name of the designated request queue. The request receiver is a subscriber to the request queue. After a request message is received, the request receiver retrieves the value of the replyTo
property from the message header, creates a response message, and sends it to the default exchange with a routing key that matches the replyTo
property. This means that the replyTo
property points to a queue that handles response messages and the sender is subscribed to that queue in order to receive a response.
Let's extend our Sender
class with the following sendRequest()
method, which sends a message to the request_exchange
exchange, and the receiveResponse()
method, which receives a message from the response_queue
queue as follows:
private static final String REQUEST_QUEUE = "request_queue"; private static...