Publishing messages in RabbitMQ - Mini Project: Build & Apply

Publishing messages with RabbitMQ

📖 Scenario: You are setting up a simple messaging system using RabbitMQ. Your goal is to send messages to a queue so other services can receive and process them.

🎯 Goal: Learn how to publish messages to a RabbitMQ queue using Python. You will create a connection, declare a queue, send messages, and confirm the output.

📋 What You'll Learn

Use Python with the pika library to connect to RabbitMQ

Create a queue named task_queue

Publish a message with exact content 'Hello RabbitMQ!'

Print confirmation after sending the message

💡 Why This Matters

🌍 Real World

Publishing messages to queues is common in microservices to decouple components and handle tasks asynchronously.

💼 Career

Understanding message publishing with RabbitMQ is essential for roles involving backend development, DevOps, and system integration.

1

Setup RabbitMQ connection and channel

Import the pika library and create a connection to RabbitMQ on localhost. Then create a channel from this connection.

RabbitMQ

# Import pika and create connection and channel
# Your code here

Need a hint?

Use pika.BlockingConnection(pika.ConnectionParameters('localhost')) to connect.

2

Declare the queue

Use the channel to declare a queue named task_queue that is durable.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Declare a durable queue named 'task_queue'
# Your code here

Need a hint?

Use channel.queue_declare(queue='task_queue', durable=True) to create the queue.

3

Publish the message

Publish the message 'Hello RabbitMQ!' to the task_queue using channel.basic_publish. Set the message property delivery_mode=2 to make it persistent.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
# Publish 'Hello RabbitMQ!' message to 'task_queue' with delivery_mode=2
# Your code here

Need a hint?

Use channel.basic_publish(exchange='', routing_key='task_queue', body='Hello RabbitMQ!', properties=pika.BasicProperties(delivery_mode=2)).

4

Print confirmation and close connection

Print '[x] Sent Hello RabbitMQ!' to confirm the message was sent. Then close the connection.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)
channel.basic_publish(
    exchange='',
    routing_key='task_queue',
    body='Hello RabbitMQ!',
    properties=pika.BasicProperties(delivery_mode=2)
)
# Print confirmation and close connection
# Your code here

Need a hint?

Use print('[x] Sent Hello RabbitMQ!') and connection.close().