Reply-to queue pattern in RabbitMQ - Practice Problems & Coding Challenges

Challenge - 5 Problems

🧠 Conceptual

intermediate

Understanding the purpose of the reply-to queue in RabbitMQ

What is the main purpose of the reply-to queue in the RabbitMQ reply-to queue pattern?

A It acts as a dead-letter queue for expired messages.

B It defines the queue where the original request message is published.

C It specifies the queue where the consumer should send the response message.

D It is used to store messages that failed to be delivered.

💡 Hint

Think about how the consumer knows where to send the reply.

The reply-to property tells the consumer which queue to send the response message back to, enabling request-response communication.

💻 Command Output

intermediate

Output of a basic RabbitMQ reply-to usage in Python

Given the following Python code snippet using pika to send a message with reply_to set, what will be printed by the consumer?

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue')

# Producer sends a message with reply_to
channel.basic_publish(
    exchange='',
    routing_key='task_queue',
    properties=pika.BasicProperties(reply_to='response_queue'),
    body='Hello')

print('Message sent with reply_to=response_queue')

A Message sent with reply_to=response_queue

B Error: reply_to property missing

C Message sent with reply_to=task_queue

D No output

💡 Hint

Look at the print statement after publishing the message.

The code explicitly prints the message confirmation with the reply_to value set to 'response_queue'.

❓ Configuration

advanced

Correct RabbitMQ consumer configuration for reply-to pattern

Which of the following consumer configurations correctly uses the reply_to property to send a response back to the producer?

A

channel.basic_consume(queue='task_queue', on_message_callback=callback)

def callback(ch, method, properties, body):
    response = body.decode().upper()
    ch.basic_publish(exchange='reply_exchange', routing_key=properties.reply_to, body=response)
    ch.basic_ack(delivery_tag=method.delivery_tag)

B

channel.basic_consume(queue='task_queue', on_message_callback=callback)

def callback(ch, method, properties, body):
    response = body.decode().lower()
    ch.basic_publish(exchange='', routing_key='task_queue', body=response)
    ch.basic_ack(delivery_tag=method.delivery_tag)

C

channel.basic_consume(queue='task_queue', on_message_callback=callback)

def callback(ch, method, properties, body):
    response = body.decode().upper()
    ch.basic_publish(exchange='', routing_key='', body=response)
    ch.basic_ack(delivery_tag=method.delivery_tag)

D

channel.basic_consume(queue='task_queue', on_message_callback=callback)

def callback(ch, method, properties, body):
    response = body.decode().upper()
    ch.basic_publish(exchange='', routing_key=properties.reply_to, body=response)
    ch.basic_ack(delivery_tag=method.delivery_tag)

💡 Hint

Check how the response is sent back using the reply_to property and the exchange.

Option D correctly uses properties.reply_to as the routing key and publishes to the default exchange (''). This sends the response to the queue specified by the producer.

❓ Troubleshoot

advanced

Diagnosing missing replies in reply-to pattern

A developer uses the reply-to queue pattern but notices the producer never receives replies. Which of the following is the most likely cause?

A The producer did not set the <code>reply_to</code> property in the request message.

B The consumer publishes the response to a different exchange than the default ('').

C The consumer did not acknowledge the request message.

D The producer queue is not declared before sending the request.

💡 Hint

Think about how the consumer knows where to send the reply.

If the reply_to property is missing, the consumer does not know where to send the response, so no reply is received.

🔀 Workflow

expert

Correct sequence of steps in the RabbitMQ reply-to queue pattern

Arrange the following steps in the correct order for a typical RabbitMQ reply-to queue pattern workflow.

A 2,1,3,4

B 1,2,3,4

C 1,3,2,4

D 2,3,1,4

💡 Hint

Think about what the producer must do before sending the request.

The producer first creates a temporary queue to receive replies, then sends the request with reply_to set, the consumer processes and replies, and finally the producer consumes the reply.