|
|
| Author |
Message |
|
| Guest |
 Posted: Sun Mar 02, 2008 10:40 pm |
 |
|
|
Guest
|
We put together an add-on for py-amqplib that implements AMQP client with non-blocking
sockets (see NonBlockingConnection class and nbloop() function in nbclient_0_8.py).
nbdemo_receive.py is a demo script, and nbclient.zip includes both nbclient_0_8.py and
nbdemo_receive.py.
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.
I would like to acknowledge Barry Pederson who created py-amqplib library and made it
available to the list (see his original announcement at
http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2007-December/000750.html ).
- Dmitriy
Post recived from mailinglist |
|
|
| Back to top |
|
| Guest |
| Posted: Mon Mar 03, 2008 3:47 pm |
|
|
|
Guest
|
Dmitriy Samovskiy wrote:
>
> We put together an add-on for py-amqplib that implements AMQP client
> with non-blocking
> sockets (see NonBlockingConnection class and nbloop() function in
> nbclient_0_8.py).
> nbdemo_receive.py is a demo script, and nbclient.zip includes both
> nbclient_0_8.py and
> nbdemo_receive.py.
Thanks Dmitriy, I've added this to my Mercurial repository
http://hg.barryp.org/py-amqplib/ and made a couple small tweaks to
streamline the code a bit.
I'll take a look at factoring out the common code that's in the
Connection.__init__ and NonBlockingConnection.__init__ methods.
Barry
_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss@lists.rabbitmq.com
http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
Post recived from mailinglist |
|
|
| Back to top |
|
|
|
All times are GMT
|
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
You cannot attach files in this forum
You cannot download files in this forum
|
|
|
Digg It
Del.icio.us
Reddit
Facebook
Stumble Upon
Technorati
