Headers exchange in RabbitMQ - Mini Project: Build & Apply

Headers Exchange in RabbitMQ

📖 Scenario: You are setting up a messaging system using RabbitMQ. You want to route messages based on multiple header values instead of routing keys. This is useful when messages need to be filtered by several attributes, like type and priority.

🎯 Goal: Build a RabbitMQ headers exchange setup where messages are routed to queues based on matching header values.

📋 What You'll Learn

Create a headers exchange named logs_headers

Create two queues named queue_errors and queue_warnings

Bind queue_errors to logs_headers with headers {'type': 'error', 'severity': 'high'} and x-match set to all

Bind queue_warnings to logs_headers with headers {'type': 'warning'} and x-match set to any

Publish messages with headers to logs_headers and verify routing

💡 Why This Matters

🌍 Real World

Headers exchanges are used in messaging systems where routing depends on multiple message attributes, like filtering logs by type and severity.

💼 Career

Understanding headers exchanges helps in designing flexible message routing in distributed systems, a key skill for DevOps and backend engineers.

1

Create a headers exchange and two queues

Create a headers exchange called logs_headers. Then create two queues named queue_errors and queue_warnings.

RabbitMQ

# Your code here to declare exchange and queues

Need a hint?

Use exchange_declare with exchange_type='headers'. Use queue_declare to create queues.

2

Bind queues to the headers exchange with header arguments

Bind queue_errors to logs_headers with headers {'type': 'error', 'severity': 'high', 'x-match': 'all'}. Bind queue_warnings to logs_headers with headers {'type': 'warning', 'x-match': 'any'}.

RabbitMQ

channel.exchange_declare(exchange='logs_headers', exchange_type='headers')
channel.queue_declare(queue='queue_errors')
channel.queue_declare(queue='queue_warnings')
# Your code here to bind queues with headers

Need a hint?

Use queue_bind with arguments to specify headers and x-match values.

3

Publish messages with headers to the headers exchange

Publish a message with headers {'type': 'error', 'severity': 'high'} and body 'Error occurred' to logs_headers. Also publish a message with headers {'type': 'warning'} and body 'Warning issued'.

RabbitMQ

channel.exchange_declare(exchange='logs_headers', exchange_type='headers')
channel.queue_declare(queue='queue_errors')
channel.queue_declare(queue='queue_warnings')
channel.queue_bind(queue='queue_errors', exchange='logs_headers', arguments={'type': 'error', 'severity': 'high', 'x-match': 'all'})
channel.queue_bind(queue='queue_warnings', exchange='logs_headers', arguments={'type': 'warning', 'x-match': 'any'})
# Your code here to publish messages with headers

Need a hint?

Use basic_publish with properties=pika.BasicProperties(headers=...) to send headers.

4

Consume and print messages from both queues

Consume one message from queue_errors and print its body. Then consume one message from queue_warnings and print its body.

RabbitMQ

channel.exchange_declare(exchange='logs_headers', exchange_type='headers')
channel.queue_declare(queue='queue_errors')
channel.queue_declare(queue='queue_warnings')
channel.queue_bind(queue='queue_errors', exchange='logs_headers', arguments={'type': 'error', 'severity': 'high', 'x-match': 'all'})
channel.queue_bind(queue='queue_warnings', exchange='logs_headers', arguments={'type': 'warning', 'x-match': 'any'})
channel.basic_publish(exchange='logs_headers', routing_key='', body='Error occurred', properties=pika.BasicProperties(headers={'type': 'error', 'severity': 'high'}))
channel.basic_publish(exchange='logs_headers', routing_key='', body='Warning issued', properties=pika.BasicProperties(headers={'type': 'warning'}))
# Your code here to consume and print messages

Need a hint?

Use basic_get to get messages from queues and print their bodies decoded as strings.