Attachment 942414 Details for Bug 1128170 – rabbit AMQP test script

rabbit AMQP test script

rabbit.py (text/plain), 1.03 KB, created by Rob Crittenden on 2014-09-29 16:16:45 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Rob Crittenden

Created: 2014-09-29 16:16:45 UTC

Size: 1.03 KB

patch

obsolete

>from amqplib import client_0_8 as amqp
>import sys
>
># callback to handle received data
>def recv_callback(msg):
>     print msg.body
>
>server = 'rabbit.example.com:5671'
>username = 'openstack'
>password = 'rabbit_password_hash'
>
>lConnection = amqp.Connection(host=server, userid=username, password=password, ssl=True)
>
># Create a channel and declare a direct queue and exhange
>lChannel = lConnection.channel()
>lChannel.queue_declare(queue='echoQueue', durable=True, exclusive=False, auto_delete=False)
>lChannel.exchange_declare(exchange='echoExchange', type='direct', durable=True, auto_delete=False)
>lChannel.queue_bind(queue='echoQueue', exchange='echoExchange', routing_key='Echo')
>
>lMessage = amqp.Message('Hello World!')
>
># register as a consumer
>lChannel.basic_consume(queue='echoQueue', no_ack=True, callback=recv_callback, consumer_tag='EchoTag')
>
># publish our message to echo back
>lChannel.basic_publish(lMessage, exchange='echoExchange', routing_key='Echo')
>
>lChannel.wait()
>
>lChannel.basic_cancel('EchoTag')
>
>lChannel.close()
>lConnection.close()

Actions: View

Attachments on bug 1128170: 942414