We put together an add-on for py-amqplib that implements AMQP client with non-blocking sockets in python.
There are at least 2 scenarios where non-blocking sockets help, and both are applicable to consumers:
1) when you want to be able to interrupt consumer’s event loop without waiting for a next incoming message;
2) when you want to consume messages from multiple brokers (or over multiple connections) in a single event loop.
Special thanks to Barry Pederson who created py-amqplib library and made it available to the public.
Please see my announcement on rabbitmq-discuss mailing list . If your architecture still relies on custom or proprietary messaging protocols, I strongly suggest that you take a look at AMQP and especially RabbitMQ.
UPDATED: You can download the add-on directly from http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20080302/455b87df/attachment.txt
0 responses so far ↓
There are no comments yet...Kick things off by filling out the form below.
Leave a Comment