In [ ]:

    

import rabbitpy


    

In [ ]:

    

# The URL to connect to
url = 'amqp://guest:guest@localhost:5672/%2F'


    

In [ ]:

    

# Open a connection to RabbitMQ
connection = rabbitpy.Connection(url)


    

In [ ]:

    

# Open a channel to communicate with RabbitMQ on
channel = connection.channel()


    

In [ ]:

    

# Create an object for interacting with the queue
queue = rabbitpy.Queue(channel, 'example')


    

In [ ]:

    

# While there are messages in the queue, fetch them using Basic.Get
while len(queue) > 0:
    message = queue.get()
    print('Message:')
    print(' ID: %s' % message.properties['message_id'])
    print(' Time: %s' % message.properties['timestamp'].isoformat())
    print(' Body: %s' % message.body)
    message.ack()