Silas Sewell

Build using Fedora

1. Install the RPM development tools

   sudo yum install rpmdevtools mock
   

2. Add yourself to the mock group

   sudo /usr/sbin/usermod --groups mock --append $USER
   

3. Setup build directories

   rpmdev-setuptree
   

4. Install spec and source files (or get latest here)

   rpm -i ftp://ftp.redhat.com/pub/redhat/linux/enterprise/5Server/en/RHEMRG/SRPMS/qpidc-0.5.752581-17.el5.src.rpm
   rpm -i ftp://ftp.redhat.com/pub/redhat/linux/enterprise/5Server/en/RHEMRG/SRPMS/amqp-1.0.750054-1.el5.src.rpm
   rpm -i ftp://ftp.redhat.com/pub/redhat/linux/enterprise/5Server/en/RHEMRG/SRPMS/python-qpid-0.5.752581-3.el5.src.rpm
   

5. Build qpidc

   rpmbuild -bs --nodeps ~/rpmbuild/SRPM/qpidc.spec
   mock -vr epel-5-x86_64 ~/rpmbuild/SRPMS/qpidc-*.src.rpm
   scp /var/lib/mock/epel-5-x86_64/result/*.rpm CENTOS_HOST:SOME_PATH
   

6. Build amqp

   rpmbuild -bs --nodeps ~/rpmbuild/SPECS/amqp.spec
   mock -vr epel-5-x86_64 ~/rpmbuild/SRPMS/amqp-*.src.rpm
   scp /var/lib/mock/epel-5-x86_64/result/*.rpm CENTOS_HOST:SOME_PATH
   

7. Build python-qpid

   rpmbuild -bs --nodeps ~/rpmbuild/SPECS/python-qpid.spec
   mock -vr epel-5-x86_64 ~/rpmbuild/SRPMS/python-qpid-*.src.rpm
   scp /var/lib/mock/epel-5-x86_64/result/*.rpm CENTOS_HOST:SOME_PATH
   

Install on CentOS

1. Become root

   sudo su -
   

2. Install Qpid server and Python client packages

   cd SOME_PATH
   yum localinstall --nogpgcheck qpidc-*.el5.x86_64.rpm qpidd-*.el5.x86_64.rpm amqp-*.el5.noarch.rpm python-qpid-*.el5.noarch.rpm
   

3. Disable auth for testing

   echo 'auth=no' >> /etc/qpidd.conf
   

4. Start qpidd

   service qpidd start
   

5. Test using these instructions.

NOTE: I realize you can build the SRPMs without installing them.

The Advanced Message Queuing Protocol (AMQP) is the first open standard for Enterprise Messaging and has been adopted by Cisco, [Microsoft][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