Timeout handling in RPC in RabbitMQ - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to set a timeout for the RPC call.

RabbitMQ

channel.basic_publish(exchange='', routing_key='rpc_queue', properties=pika.BasicProperties(reply_to=callback_queue, correlation_id=corr_id), body=request_body)
channel.connection.process_data_events(time_limit=[1])

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

A5

B-1

C0

D10

Attempts:

3 left

💡 Hint

Common Mistakes

Using 0 or negative values disables the timeout.

The process_data_events method with time_limit=10 sets a 10-second timeout for waiting for the RPC response.

2fill in blank

medium

Complete the code to raise an exception if the RPC response is not received in time.

RabbitMQ

if response is None:
    raise [1]('RPC call timed out')

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

ATimeoutError

BValueError

CKeyError

DRuntimeError

Attempts:

3 left

💡 Hint

Common Mistakes

Using exceptions unrelated to timeouts like ValueError.

TimeoutError is the appropriate exception to indicate a timeout occurred.

3fill in blank

hard

Fix the error in the code to correctly check the correlation ID in the RPC response.

RabbitMQ

if props.correlation_id != [1]:
    return

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

AcorrelationId

Bcorr_id

CcorrId

Dcorrelation_id

Attempts:

3 left

💡 Hint

Common Mistakes

Using incorrect variable names that cause NameError.

The variable corr_id holds the correlation ID to match the response.

4fill in blank

hard

Fill both blanks to set up the callback queue and consume messages with a timeout.

RabbitMQ

result = channel.queue_declare(queue='', exclusive=True)
callback_queue = result.[1]
channel.basic_consume(queue=callback_queue, on_message_callback=[2], auto_ack=True)

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

Amethod.queue

Bcallback

Cqueue

Dconsume

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong attribute names causing AttributeError.

queue_declare returns an object with the queue name in method.queue. The callback function is passed as callback.

5fill in blank

hard

Fill all three blanks to create a dictionary comprehension that filters responses received within the timeout.

RabbitMQ

responses = {corr_id: body for corr_id, body in messages.items() if body is not None and corr_id [1] [2]

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

Ain

Btimeout

Cvalid_ids

Dand

Attempts:

3 left

💡 Hint

Common Mistakes

Using wrong operators causing syntax errors.

The comprehension checks if corr_id is in valid_ids and combines conditions with and.

Practice

1. What is the main purpose of timeout handling in RabbitMQ RPC?

easy

A. To increase the message queue size automatically

B. To retry sending messages indefinitely

C. To stop waiting for a reply after a set time to keep the app responsive

D. To encrypt messages during transmission

Solution

1. Step 1: Understand RPC timeout concept

   Timeout handling means stopping the wait for a reply after a certain time to avoid freezing.

2. Step 2: Identify the purpose in RabbitMQ RPC

   This keeps the application responsive by not waiting forever for a reply that might never come.

3. Final Answer:

   To stop waiting for a reply after a set time to keep the app responsive -> Option C

4. Quick Check:

   Timeout handling = stop waiting after set time [OK]

Hint: Timeout means stop waiting after set time to avoid freeze [OK]

Common Mistakes:

• Thinking timeout increases queue size
• Assuming timeout retries messages endlessly
• Confusing timeout with message encryption

2. Which of the following is the correct way to set a timeout in RabbitMQ RPC client code using Python?

easy

A. response = channel.basic_get(queue='rpc_queue', timeout=5)

B. response = rpc_client.call(request, timeout=5)

C. response = rpc_client.call(request); time.sleep(5)

D. response = rpc_client.call(request, wait_forever=True)

Solution

1. Step 1: Identify correct timeout usage in RPC call

   Timeout is usually passed as a parameter to the call method to limit wait time.

2. Step 2: Check options for correct syntax

   response = rpc_client.call(request, timeout=5) shows passing timeout=5 directly to the call method, which is correct.

3. Final Answer:

   response = rpc_client.call(request, timeout=5) -> Option B

4. Quick Check:

   Timeout param in call() = response = rpc_client.call(request, timeout=5) [OK]

Hint: Timeout is a parameter inside the RPC call method [OK]

Common Mistakes:

• Using timeout in basic_get which doesn't support it
• Sleeping after call instead of setting timeout
• Using wait_forever=True disables timeout

3. Given this Python RPC client snippet, what will happen if the server does not reply within 3 seconds?

try:
    response = rpc_client.call(request, timeout=3)
    print(response)
except TimeoutError:
    print('Request timed out')

medium

A. The program crashes with an unhandled exception

B. The program waits forever until a response arrives

C. The program prints the server response after 3 seconds

D. The program prints 'Request timed out' after 3 seconds

Solution

1. Step 1: Analyze the try-except block with timeout

   The call method waits up to 3 seconds for a reply, then raises TimeoutError if none.

2. Step 2: Understand exception handling

   The except block catches TimeoutError and prints 'Request timed out'.

3. Final Answer:

   The program prints 'Request timed out' after 3 seconds -> Option D

4. Quick Check:

   TimeoutError caught = prints timeout message [OK]

Hint: Timeout triggers exception caught to print timeout message [OK]

Common Mistakes:

• Assuming program waits forever
• Expecting response after timeout
• Thinking program crashes without handling

4. You wrote this code but it never times out:

try:
    response = rpc_client.call(request)
except TimeoutError:
    print('Timeout!')

What is the likely error?

medium

A. You forgot to set the timeout parameter in the call method

B. You used the wrong exception type for timeout

C. You did not import the TimeoutError exception

D. You called the method outside a try block

Solution

1. Step 1: Check if timeout parameter is set

   The call method has no timeout argument, so it waits indefinitely.

2. Step 2: Confirm exception handling

   Without timeout set, TimeoutError is never raised, so except block never runs.

3. Final Answer:

   You forgot to set the timeout parameter in the call method -> Option A

4. Quick Check:

   No timeout param = no TimeoutError raised [OK]

Hint: Always set timeout param to trigger TimeoutError [OK]

Common Mistakes:

• Assuming exception triggers without timeout set
• Using wrong exception type
• Not wrapping call in try block

5. You want to implement a RabbitMQ RPC client that retries the call up to 3 times if a timeout occurs. Which code snippet correctly handles this?

hard

A. for i in range(3):
try:
response = rpc_client.call(request, timeout=5)
break
except TimeoutError:
if i == 2:
raise
print('Retrying...')

B. response = rpc_client.call(request, timeout=5)
if response is None:
print('Retrying...')

C. while True:
response = rpc_client.call(request)
if response:
break

D. try:
response = rpc_client.call(request)
except Exception:
print('Retrying...')

Solution

1. Step 1: Understand retry logic with timeout

   We need a loop that tries up to 3 times, catching TimeoutError each time.

2. Step 2: Analyze each option for correct retry and timeout handling

   for i in range(3): try: response = rpc_client.call(request, timeout=5) break except TimeoutError: if i == 2: raise print('Retrying...') uses a for loop with try-except, retries on TimeoutError, and stops after 3 tries.

3. Final Answer:

   for i in range(3): try: response = rpc_client.call(request, timeout=5) break except TimeoutError: if i == 2: raise print('Retrying...') -> Option A

4. Quick Check:

   Retry loop with timeout and exception = for i in range(3): try: response = rpc_client.call(request, timeout=5) break except TimeoutError: if i == 2: raise print('Retrying...') [OK]

Hint: Use try-except inside loop with timeout param for retries [OK]

Common Mistakes:

• Not catching TimeoutError specifically
• No timeout set in call method
• Infinite loop without break condition