Correlation ID for matching replies in RabbitMQ - Cheat Sheet & Quick Revision

Recall & Review

beginner

What is a Correlation ID in RabbitMQ?

A Correlation ID is a unique identifier used to match a request message with its reply message in RabbitMQ communication.

beginner

Why is Correlation ID important in RPC (Remote Procedure Call) over RabbitMQ?

It helps the client identify which reply corresponds to which request, especially when multiple requests are sent asynchronously.

intermediate

How is Correlation ID typically set in a RabbitMQ message?

It is set as a property in the message header before sending the request, usually as a unique string like a UUID.

intermediate

What happens if you do not use Correlation ID when expecting replies in RabbitMQ?

The client may not be able to match replies to their original requests, causing confusion or incorrect processing of responses.

beginner

In RabbitMQ, which property is commonly used to specify the queue where the reply should be sent?

The 'reply_to' property is used to specify the queue where the server should send the reply message.

What is the main purpose of the Correlation ID in RabbitMQ messaging?

A To define the message expiration time

B To encrypt the message content

C To specify the message priority

D To match replies with their original requests

The Correlation ID uniquely identifies a request so the client can match the reply to it.

Which RabbitMQ message property is used to tell the server where to send the reply?

A correlation_id

B content_type

C reply_to

D delivery_mode

The 'reply_to' property specifies the queue for the reply message.

If multiple requests are sent without Correlation IDs, what problem can occur?

A Messages will be lost

B Replies cannot be matched to requests

C Messages will be duplicated

D Messages will be encrypted

Without Correlation IDs, the client cannot tell which reply belongs to which request.

What type of value is usually used as a Correlation ID?

A A unique string like a UUID

B A timestamp only

C A fixed number

D The message body

A unique string such as a UUID ensures each request can be uniquely identified.

In RabbitMQ RPC, where is the Correlation ID set?

A In the message header properties

B In the exchange name

C In the queue name

D In the message body

Correlation ID is set in the message header properties before sending the request.

Explain how Correlation ID helps in matching replies to requests in RabbitMQ RPC.

Think about how you find your friend in a crowd by a unique feature.

Describe the roles of 'correlation_id' and 'reply_to' properties in RabbitMQ messaging.

One is like a name tag, the other is like an address.

Practice

1. What is the main purpose of the correlation_id property in RabbitMQ messaging?

easy

A. To specify the message priority in the queue

B. To link a reply message to its original request message

C. To encrypt the message content for security

D. To define the message expiration time

Solution

1. Step 1: Understand message flow in request-reply pattern

   In RabbitMQ, when a client sends a request, it expects a reply. The correlation_id helps identify which reply matches which request.

2. Step 2: Identify the role of correlation_id

   The correlation_id is set in the request message and copied to the reply, so the client can match them correctly.

3. Final Answer:

   To link a reply message to its original request message -> Option B

4. Quick Check:

   Correlation ID = Link request and reply [OK]

Hint: Correlation ID connects request and reply messages [OK]

Common Mistakes:

• Thinking correlation_id encrypts messages
• Confusing correlation_id with message priority
• Assuming correlation_id sets message expiration

2. Which of the following is the correct way to set the correlation_id property when publishing a message in RabbitMQ using Python pika library?

easy

A. channel.send(exchange='', routing_key='queue', body='msg', properties={'correlation': '123'})

B. channel.publish(exchange='', routing_key='queue', body='msg', correlation_id='123')

C. channel.basic_publish(exchange='', routing_key='queue', body='msg', properties=pika.BasicProperties(correlation_id='123'))

D. channel.basic_send(exchange='', routing_key='queue', body='msg', correlation='123')

Solution

1. Step 1: Recall pika syntax for setting message properties

   In pika, message properties are set using pika.BasicProperties with named arguments like correlation_id.

2. Step 2: Identify correct method and property usage

   The correct method is basic_publish and the property is correlation_id inside BasicProperties.

3. Final Answer:

   channel.basic_publish(exchange='', routing_key='queue', body='msg', properties=pika.BasicProperties(correlation_id='123')) -> Option C

4. Quick Check:

   Use basic_publish + BasicProperties(correlation_id) [OK]

Hint: Use BasicProperties with correlation_id in basic_publish [OK]

Common Mistakes:

• Using wrong method like publish or send
• Passing correlation_id outside BasicProperties
• Using incorrect property name like 'correlation'

3. Given the following Python code snippet using pika, what will be printed?

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

corr_id = 'abc123'

channel.basic_publish(
    exchange='',
    routing_key='rpc_queue',
    body='Request',
    properties=pika.BasicProperties(correlation_id=corr_id, reply_to='reply_queue')
)

print(corr_id)

medium

A. abc123

B. Request

C. None

D. Error: correlation_id not defined

Solution

1. Step 1: Analyze variable assignment and usage

   The variable corr_id is assigned the string 'abc123' before publishing the message.

2. Step 2: Understand the print statement

   The print statement outputs the value of corr_id, which is 'abc123'. The message publishing does not affect this variable.

3. Final Answer:

   abc123 -> Option A

4. Quick Check:

   Print variable corr_id = abc123 [OK]

Hint: Print variable directly, not message body [OK]

Common Mistakes:

• Confusing printed output with message body
• Expecting None because of message publish
• Assuming error due to correlation_id usage

4. You wrote this code to match replies by correlation ID but it never matches. What is the likely error?

def on_response(ch, method, props, body):
    if props.correlation_id == corr_id:
        print('Reply matched:', body)

channel.basic_consume(queue='reply_queue', on_message_callback=on_response, auto_ack=True)

medium

A. The variable corr_id is not defined in the callback scope

B. The auto_ack parameter should be False

C. The correlation_id property is not set in the reply message

D. The queue name 'reply_queue' is incorrect

Solution

1. Step 1: Check variable scope in callback function

   The callback uses corr_id but it is not passed or declared inside the function, causing a NameError or mismatch.

2. Step 2: Understand variable scope and fix

   To fix, corr_id should be accessible inside on_response, either by passing it or declaring as global or closure variable.

3. Final Answer:

   The variable corr_id is not defined in the callback scope -> Option A

4. Quick Check:

   corr_id must be in callback scope [OK]

Hint: Ensure corr_id is accessible inside callback function [OK]

Common Mistakes:

• Ignoring variable scope issues
• Changing auto_ack unnecessarily
• Assuming queue name is wrong without checking

5. You want to implement a RabbitMQ RPC client that sends multiple requests and matches replies correctly. Which approach best uses correlation_id to handle multiple outstanding requests?

hard

A. Use the same correlation_id for all requests to simplify matching

B. Set correlation_id only on the first request and ignore for others

C. Do not set correlation_id and rely on message order in the queue

D. Generate a unique correlation_id for each request and store a mapping of IDs to callbacks or futures

Solution

1. Step 1: Understand multiple outstanding requests scenario

   When sending many requests, replies can arrive in any order, so each must be uniquely identified.

2. Step 2: Use unique correlation IDs and mapping

   Assign a unique correlation_id per request and keep a map from ID to the request handler (callback or future) to match replies correctly.

3. Final Answer:

   Generate a unique correlation_id for each request and store a mapping of IDs to callbacks or futures -> Option D

4. Quick Check:

   Unique correlation_id + mapping = correct reply matching [OK]

Hint: Use unique correlation_id per request with a map [OK]

Common Mistakes:

• Using same correlation_id for all requests
• Ignoring correlation_id and relying on order
• Setting correlation_id only once