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.


Aurélien Bompard

Tél : +33 1 41 28 44 33

Mailing list: https://launchpad.net/~txamqp-user
Post to     : txamqp-user@lists.launchpad.net
Unsubscribe : https://launchpad.net/~txamqp-user
More help   : https://help.launchpad.net/ListHelp

Reply via email to