RabbitMQ primer RPC

client.py

import pika
import sys

import logging
logging.basicConfig(level=logging.CRITICAL)

params = pika.URLParameters('amqp://guest:guest@localhost:5672/%2F')
conn = pika.BlockingConnection(params)
ch = conn.channel()

ch.queue_declare('taskrabbit')

ok = ch.queue_declare(exclusive=True)
mailbox = ok.method.queue

ch.basic_publish('', 'taskrabbit', sys.argv[1],
                 properties=pika.BasicProperties(reply_to=mailbox))

try:
    for (f, h, b) in ch.consume(mailbox):
        print b
        ch.basic_ack(f.delivery_tag)
        break
except KeyboardInterrupt:
    pass

conn.close()

server.py

import pika
import sys

import logging
logging.basicConfig(level=logging.CRITICAL)

params = pika.URLParameters('amqp://guest:guest@localhost:5672/%2F')
conn = pika.BlockingConnection(params)
ch = conn.channel()

ch.queue_declare('taskrabbit')

try:
    for (f, h, req) in ch.consume(queue='taskrabbit'):
        replyto = h.reply_to
        reply = req.upper()
        print("Got '%s', responding '%s'", (req, reply))
        ch.basic_publish('', replyto, reply)
        ch.basic_ack(f.delivery_tag)
except KeyboardInterrupt:
    conn.close()