What is a message queue in RabbitMQ - Hands-On Activity

What is a message queue

📖 Scenario: Imagine you run a bakery where orders come in from customers. You want to make sure each order is handled one by one without losing any. A message queue helps you organize these orders so your bakery can work smoothly.

🎯 Goal: You will create a simple message queue setup using RabbitMQ concepts. You will define a queue, send messages (orders) to it, and then receive messages from it. This will show how message queues help manage tasks in order.

📋 What You'll Learn

Create a queue named order_queue

Send three messages: Order1, Order2, Order3 to the queue

Receive and print messages from the queue one by one

💡 Why This Matters

🌍 Real World

Message queues are used in many systems like online stores, banking, and social media to handle tasks reliably and in order.

💼 Career

Understanding message queues is important for DevOps roles to manage communication between different parts of software systems efficiently.

1

Create a queue named order_queue

Write code to declare a queue called order_queue using RabbitMQ client methods.

RabbitMQ

# Your code here to declare the queue named 'order_queue'

Need a hint?

Use channel.queue_declare with the queue parameter set to 'order_queue'.

2

Send three messages Order1, Order2, Order3 to order_queue

Write code to send messages 'Order1', 'Order2', and 'Order3' to the queue order_queue using channel.basic_publish.

RabbitMQ

channel.queue_declare(queue='order_queue')
# Your code here to send 'Order1', 'Order2', and 'Order3' to 'order_queue'

Need a hint?

Use channel.basic_publish with exchange='', routing_key='order_queue', and body set to each order message.

3

Receive messages from order_queue one by one

Write code to get messages from order_queue using channel.basic_get and print each message body as a string.

RabbitMQ

channel.queue_declare(queue='order_queue')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order1')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order2')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order3')
# Your code here to receive and print messages from 'order_queue'

Need a hint?

Use a loop to call channel.basic_get(queue='order_queue'), decode the body to string, print it, and acknowledge the message with channel.basic_ack.

4

Print the messages received from the queue

Write code to print each message received from order_queue exactly as it was sent: Order1, Order2, Order3.

RabbitMQ

channel.queue_declare(queue='order_queue')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order1')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order2')
channel.basic_publish(exchange='', routing_key='order_queue', body='Order3')

for _ in range(3):
    method_frame, header_frame, body = channel.basic_get(queue='order_queue')
    if method_frame:
        # Your code here to print the message body
        print(body.decode())
        channel.basic_ack(method_frame.delivery_tag)

Need a hint?

Make sure to print each message body decoded to string exactly as sent.