Skip to content
A very simple way to interact with python AMQPlib.
Python
Pull request Compare This branch is 2 commits ahead of nathanborror:master.
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.
flopsy
.gitignore
AUTHORS
LICENSE
README

README

Flopsy
======

A very simple way to interact with python AMQPlib. For my case I'm using
RabbitMQ as my implementation but it should work with others.

Consumer
--------

>>> import flopsy
>>> rabbit = flopsy.Broker()
>>> consumer = flopsy.Consumer(rabbit)
>>> def message_callback(message):
...     print 'Recieved: ' + message.body
...
>>> consumer.register('message_to_print', message_callback)
>>> consumer.wait()


Publisher
---------

>>> import flopsy
>>> rabbit = flopsy.Broker()
>>> publisher = flopsy.Publisher(rabbit)
>>> publisher.send('message_to_print', 'Test message!')
Something went wrong with that request. Please try again.