txamqp-user team mailing list archive

[Aurélien Bompard <aurelien.bompard@xxxxxx>]

Hi all,

I'm considering the conversion of my applicative messenging system from 
XMPP to AMQP, and since I'm currently using Twisted I'm evaluating txAMQP.
So far, it looks good, even if txAMQP is not as advanced as wokkel is 
for the XMPP protocol (but maybe we can change that...)

I'm having a little problem though. I'd like to get my messages from the 
rabbitmq server queue one by one, and unless I'm mistaken txAMQP can't 
do that. Apparently, messages in the server queue are consumed as fast 
as possible and put in a DeferredQueue object, from which I can get them 
one by one via get().
However, I have a lot of messages going through my system, and I'd 
rather have rabbitmq serve as the queue storage area than the client, 
which has less RAM and performs relatively long-running operations (I 
have many of them).

I have written a sample code to demonstrate what I'm talking about : 
http://dpaste.com/hold/696982/
It starts a queue listener and prints the memory usage with guppy every 
half second. It stops after 3 seconds.
Point it to a full server queue and see the memory usage increase.

Did I do something wrong ? If not, I'm ready to help with a solution, 
but I'll need some help at the beginning.

Regards,

Aurélien Bompard

--
http://www.projet-vigilo.org
http://www.c-s.fr/LL_r168.html
Tél : +33 1 41 28 44 33