Why integration patterns connect systems in RabbitMQ - Test Your Understanding

Practice - 5 Tasks

1fill in blank

easy

Complete the code to declare a RabbitMQ queue named 'task_queue'.

RabbitMQ

channel.queue_declare(queue=[1])

Drag options to blanks, or click blank then click option'

A'connection'

B'exchange'

C'routing_key'

D'task_queue'

Attempts:

3 left

💡 Hint

Common Mistakes

Using exchange or routing_key instead of queue name.

The queue_declare method needs the queue name as a string. Here, 'task_queue' is the correct queue name.

2fill in blank

medium

Complete the code to publish a message 'Hello World!' to the default exchange with routing key 'task_queue'.

RabbitMQ

channel.basic_publish(exchange='', routing_key=[1], body='Hello World!')

Drag options to blanks, or click blank then click option'

A'default'

B'hello'

C'task_queue'

D'message_queue'

Attempts:

3 left

💡 Hint

Common Mistakes

Using exchange name or unrelated strings as routing key.

The routing key should be the queue name 'task_queue' to send the message to that queue.

3fill in blank

hard

Fix the error in the code to consume messages from 'task_queue' with a callback function named 'callback'.

RabbitMQ

channel.basic_consume(queue=[1], on_message_callback=callback, auto_ack=True)

Drag options to blanks, or click blank then click option'

A'task_queue'

B'consume'

C'queue'

D'callback'

Attempts:

3 left

💡 Hint

Common Mistakes

Putting the callback function name instead of the queue name.

The queue parameter must be the name of the queue to consume from, which is 'task_queue'.

4fill in blank

hard

Fill both blanks to declare a durable queue and publish a persistent message to it.

RabbitMQ

channel.queue_declare(queue=[1], durable=[2])
channel.basic_publish(exchange='', routing_key=[1], body='Important task', properties=pika.BasicProperties(delivery_mode=2))

Drag options to blanks, or click blank then click option'

A'task_queue'

BTrue

CFalse

D'temp_queue'

Attempts:

3 left

💡 Hint

Common Mistakes

Using different queue names or setting durable to False.

Durable queues survive server restarts, so durable=True is needed. The queue name must be consistent in both places.

5fill in blank

hard

Fill all three blanks to create a direct exchange, bind a queue to it with a routing key, and publish a message.

RabbitMQ

channel.exchange_declare(exchange=[1], exchange_type=[2])
channel.queue_bind(queue=[3], exchange=[1], routing_key='info')
channel.basic_publish(exchange=[1], routing_key='info', body='Log message')

Drag options to blanks, or click blank then click option'

A'logs'

B'direct'

C'log_queue'

D'fanout'

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong exchange types or mismatched queue/exchange names.

A direct exchange routes messages with a specific routing key. The queue 'log_queue' is bound to the 'logs' exchange with routing key 'info'.