Topic publisher / consumer

consumer.py

import pika
import sys

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

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

ch.exchange_declare('topical', exchange_type = 'topic')
ok = ch.queue_declare()
q = ok.method.queue
ch.queue_bind(q, 'topical', sys.argv[1])

try:
    for (f, h, b) in ch.consume(queue=q):
        print "%s: %s" % (f.routing_key, b)
        ch.basic_ack(f.delivery_tag)
except KeyboardInterrupt:
    conn.close()

publisher.py

import pika
import sys

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

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

ch.exchange_declare('topical', exchange_type = 'topic')
ch.basic_publish('topical', sys.argv[1], sys.argv[2])
conn.close()