A Python client for Ruote-AMQP
Python Shell
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
RuoteAMQP
debian
examples
rpm
.gitignore
MANIFEST
README.asciidoc
license
setup.py

README.asciidoc

This python class RuoteAMQP::Participant allows you to write python Participants for Ruote

It was written as part of: http://meego.gitorious.org/meego-infrastructure-tools/boss/trees/master/integration/RuoteAMQP and is part of the route and route-amqp demo in that project.

Usage is shown below:

#!/usr/bin/python
import sys
import os
import random

from  RuoteAMQP.workitem import Workitem
from  RuoteAMQP.participant import Participant

import simplejson as json

class MyPart(Participant):
    def consume(self):
        wi = self.workitem
        print "Got a workitem:"
        print json.dumps(wi.to_h(), indent=4)
        size=random.randint(500,1000)
        print "\nSize is %s" % size
        wi.set_field("image.size", size)
        wi.set_result(True)

print "Started a python participant"
p = MyPart(ruote_queue="sizer", amqp_host="amqpvm", amqp_vhost="ruote-test")
p.run()