Skip to content

Instantly share code, notes, and snippets.

@madaboutcode

madaboutcode/amqptest.py

Last active September 4, 2015 18:29
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save madaboutcode/c82eca9635c9238f24df to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save madaboutcode/c82eca9635c9238f24df to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. Ajeesh Mohan revised this gist Sep 4, 2015. No changes.
  2. Ajeesh Mohan created this gist Sep 30, 2014.
    34 changes: 34 additions & 0 deletions amqptest.py
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,34 @@
    #!/usr/bin/env python
    import pika
    import sys

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

    channel.exchange_declare(exchange='emsp',
    type='topic')

    result = channel.queue_declare(exclusive=True)
    queue_name = result.method.queue

    binding_keys = sys.argv[1:]
    if not binding_keys:
    print >> sys.stderr, "Usage: %s [binding_key]..." % (sys.argv[0],)
    sys.exit(1)

    for binding_key in binding_keys:
    channel.queue_bind(exchange='emsp',
    queue=queue_name,
    routing_key=binding_key)

    print ' [*] Waiting for logs. To exit press CTRL+C'

    def callback(ch, method, properties, body):
    print " [x] %r:%r" % (method.routing_key, body,)

    channel.basic_consume(callback,
    queue=queue_name,
    no_ack=True)

    channel.start_consuming()