This page is no longer maintained, back to sewell.org.

Getting Started with AMQP, Qpid, Python & Fedora

The Advanced Message Queuing Protocol (AMQP) is the first open standard for Enterprise Messaging and has been adopted by Cisco, Microsoft, Novel, Red Hat and others.

One implementation of AMQP currently packaged by Red Hat and Fedora is Qpid. Qpid is a collection of brokers (C++, Java) and clients (C++, Java, Python, Ruby) which aims to be 100% AMQP Compliant.

Below is a step-by-step tutorial on getting started with Qpid and the Python client in Fedora.

1. Install the Qpid broker and Python client

   yum install qpidd python-qpid
   

2. Start the broker

   service qpidd start
   

3. Create a message producer (producer.py)

   from qpid.connection import Connection
   from qpid.datatypes import Message, uuid4
   from qpid.util import connect
   
   # Create connection and session
   socket = connect('localhost', 5672)
   connection = Connection(sock=socket, username='guest', password='guest')
   connection.start()
   session = connection.session(str(uuid4()))
   
   # Setup queue
   session.queue_declare(queue='message_queue')
   session.exchange_bind(exchange='amq.direct', queue='message_queue', binding_key='routing_key')
   
   # Setup routing properties
   properties = session.delivery_properties(routing_key='routing_key')
   
   # Send messages
   session.message_transfer(destination='amq.direct', message=Message(properties, 'Message one'))
   session.message_transfer(destination='amq.direct', message=Message(properties, 'Message two'))
   session.message_transfer(destination='amq.direct', message=Message(properties, 'Done'))
   
   # Close session
   session.close(timeout=10)
   

4. Create a message consumer (consumer.py)

   from qpid.connection import Connection
   from qpid.datatypes import RangedSet, uuid4
   from qpid.util import connect
   
   # Create connection and session
   socket = connect('localhost', 5672)
   connection = Connection(sock=socket, username='guest', password='guest')
   connection.start()
   session = connection.session(str(uuid4()))
   
   # Define local queue
   local_queue_name = 'my_local_queue'
   
   # Create local queue
   queue = session.incoming(local_queue_name)
   
   # Route messages from message_queue to my_local_queue
   session.message_subscribe(queue='message_queue', destination=local_queue_name)
   queue.start()
   
   content = ''
   
   while content != 'Done':
       # Get message from the local queue
       message = queue.get(timeout=10)
       # Get body of the message
       content = message.body
       # Accept message (removes it from the queue)
       session.message_accept(RangedSet(message.id))
       # Print message content
       print content
   
   # Close session
   session.close(timeout=10)
   

5. First run the producer and then the consumer

   Message one
   Message two
   Done
   

Source: Qpid direct example

Posted on Mar 29, 2009

Licensing information is available on the about page, for additional questions or comments feel free to contact me.