txamqp-user team mailing list archive

[David Serafini <dbs@xxxxxxxxxxx>]

I have some code using txamqp that uses @inlineCallbacks for
asynchronous operation.

Once in a while an exception will be raised under very heavy load
because a command function gets the wrong method type in the response:
e.g. a basic_consume() will raise because it gets a declare-ok that
should have been delivered to an exchange_declare() that is
simultaneously waiting for a response.  And the exchange_declare()
gets the consume-ok and also raises an exception.

Any ideas for how I can deal with this, besides forcing all the
command functions to be synchronous?

For the record, I'm using Dan Simeon's txamqp_helpers module and
running with twistd,
but I don't think that should matter.

thanks,
<dbs>