AMQP protocol overview in RabbitMQ - Practice Problems & Coding Challenges

Challenge - 5 Problems

🧠 Conceptual

intermediate

AMQP Message Routing Components

Which AMQP component is responsible for receiving messages from producers and routing them to queues based on rules?

A Binding

B Queue

C Exchange

D Channel

💡 Hint

Think about the part that directs messages, not where they are stored.

The Exchange receives messages from producers and routes them to queues using bindings and routing keys.

💻 Command Output

intermediate

AMQP Channel State After Opening

What is the expected output when you open a new AMQP channel using RabbitMQ's management CLI and check its state?

RabbitMQ

rabbitmqctl list_channels

A A list showing channel IDs with state 'closed'

B An error stating 'channel not found'

C Empty output with no channels listed

D A list showing channel IDs with state 'open'

💡 Hint

Channels are created open when established.

When a channel is opened, it appears in the list with state 'open'.

❓ Configuration

advanced

AMQP Queue Durability Setting

Which queue declaration option ensures that the queue survives RabbitMQ server restarts?

RabbitMQ

channel.queue_declare(queue='task_queue', durable=?)

A durable=False

B durable=True

C exclusive=True

D auto_delete=True

💡 Hint

Durability means persistence across restarts.

Setting durable=True makes the queue survive server restarts.

❓ Troubleshoot

advanced

AMQP Message Not Delivered to Queue

You published a message to an exchange but it never appears in the queue. Which is the most likely cause?

A No binding exists between the exchange and the queue

B The message size exceeds the maximum allowed

C The queue is set as durable

D The channel is closed after publishing

💡 Hint

Check the connection between exchange and queue.

If no binding exists, the exchange cannot route messages to the queue.

✅ Best Practice

expert

AMQP Publisher Confirms Usage

What is the main benefit of enabling publisher confirms in AMQP?

A It allows the publisher to know when messages are safely received by the broker

B It encrypts messages between publisher and broker

C It automatically retries message delivery on failure

D It compresses messages to reduce network usage

💡 Hint

Think about message delivery guarantees.

Publisher confirms provide acknowledgments from the broker that messages are received and stored.

Practice

1. What is the main purpose of the AMQP protocol in RabbitMQ?

easy

A. To create user interfaces for applications

B. To store data permanently in a database

C. To manage network security settings

D. To enable safe and reliable message communication between applications

Solution

1. Step 1: Understand AMQP's role

   AMQP is designed to help applications send messages safely and reliably.

2. Step 2: Compare options

   Only To enable safe and reliable message communication between applications describes message communication, which is AMQP's main purpose.

3. Final Answer:

   To enable safe and reliable message communication between applications -> Option D

4. Quick Check:

   AMQP = safe message communication [OK]

Hint: AMQP is about messaging, not storage or UI [OK]

Common Mistakes:

• Confusing AMQP with database storage
• Thinking AMQP manages user interfaces
• Assuming AMQP handles network security

2. Which of the following is the correct AMQP component that receives messages and stores them until consumed?

easy

A. Exchange

B. Queue

C. Binding

D. Producer

Solution

1. Step 1: Identify AMQP components

   Exchanges route messages, queues store messages, bindings link exchanges to queues, producers send messages.

2. Step 2: Match component to description

   The component that stores messages until consumed is the queue.

3. Final Answer:

   Queue -> Option B

4. Quick Check:

   Queue stores messages [OK]

Hint: Queues hold messages; exchanges route them [OK]

Common Mistakes:

• Confusing exchange with queue
• Thinking binding stores messages
• Mixing producer role with storage

3. Given the following AMQP setup: An exchange named logs is bound to a queue named error_logs with a binding key error.*. If a message is published with routing key error.database, what happens?

medium

A. The message is routed to the error_logs queue

B. The message is discarded because the routing key does not match

C. The message is routed to all queues bound to logs exchange

D. The message is stored in the exchange

Solution

1. Step 1: Understand binding key pattern

   The binding key error.* matches routing keys starting with 'error.' followed by one word.

2. Step 2: Check routing key match

   The routing key error.database matches the pattern error.*, so the message routes to error_logs queue.

3. Final Answer:

   The message is routed to the error_logs queue -> Option A

4. Quick Check:

   Routing key matches binding key pattern [OK]

Hint: Match routing key to binding pattern with wildcards [OK]

Common Mistakes:

• Assuming message is discarded on match
• Thinking message goes to all queues regardless of binding
• Believing exchanges store messages

4. You wrote this binding in RabbitMQ: channel.queue_bind(queue='task_queue', exchange='tasks', routing_key='task.*'). But messages with routing key task are not received by task_queue. What is the likely problem?

medium

A. The binding key task.* does not match routing key task

B. The queue name is incorrect

C. The exchange name is misspelled

D. The exchange was not declared with type='topic'

Solution

1. Step 1: Understand AMQP wildcard matching

   The binding key task.* matches routing keys starting with 'task.' followed by exactly one word.

2. Step 2: Check routing key task against binding key

   The routing key task has no dot (one word only), so it does not match task.* which expects two words.

3. Final Answer:

   The binding key task.* does not match routing key task -> Option A

4. Quick Check:

   Binding key task.* requires one word after 'task.' [OK]

Hint: Remember '*' matches exactly one word after dot [OK]

Common Mistakes:

• Confusing '*' (one word) with '#' (zero or more)
• Ignoring dot separator in routing keys
• Blaming queue or exchange names without checking keys

5. You want to build a system where messages about user actions are sent to different queues based on action type (e.g., login, logout, purchase). Which AMQP components and setup best achieve this?

hard

A. Use a direct exchange with queues bound using routing keys 'login', 'logout', 'purchase' respectively

B. Use a fanout exchange with all queues bound without routing keys

C. Use a topic exchange with queues bound using patterns like 'user.login', 'user.logout', 'user.purchase'

D. Use a headers exchange with queues bound by matching header 'action' values

Solution

1. Step 1: Identify routing needs

   Messages must route based on action type with flexible patterns.

2. Step 2: Match exchange type to routing

   Topic exchanges allow pattern matching like 'user.login', 'user.logout', 'user.purchase'.

3. Step 3: Compare other options

   Direct exchange requires exact keys, fanout sends to all queues, headers exchange uses headers not routing keys.

4. Final Answer:

   Use a topic exchange with queues bound using patterns like 'user.login', 'user.logout', 'user.purchase' -> Option C

5. Quick Check:

   Topic exchange = pattern routing [OK]

Hint: Use topic exchange for flexible routing patterns [OK]

Common Mistakes:

• Choosing fanout which sends all messages everywhere
• Using direct exchange without pattern flexibility
• Confusing headers exchange with routing key matching