I've been playing with Messenger and I've found I need to do this if I
want to be sure it has done what I've asked it to do:
def flush(self):
"""Call work() till there is no work left."""
while self.work(0.01): pass
I've found I need to do this after subscribe() and accept() if I want to
be sure the action has been carried out. (e.g. because I want to check
if the corresponding message has been removed from a broker.)
Is there a better way of doing this? If not should we add something like
this to messenger API?
This would be analogous to the sync() call and sync arguments in the
qpid.messaging API.
Cheers,
Alan.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
