I&#39;m got a scenario where I use a dedicated thread to write a series of messages in a loop. This thread uses BlockingConnection, calls add_on_return_callback for its channel, and when publishing, uses the mandatory=True flag.<br>
<br>I want to know when a message is being returned. However, I can&#39;t figure out what to call within my loop to give Pika the opportunity to see the Basic.Return message and invoke the callback.<br><br>I&#39;ve verified via WireShark that the Basic.Returns are coming back from the broker. However, I can&#39;t figure out what the moral equivalent of calling ioloop.start() is, so as to give Pika the an opportunity to process the basic.return messages, but without blocking indefinitely. Just for kicks I tried calling Channel.basic_get() within the loop, and (as expected), I didn&#39;t get the returned message callbacks.<br>
<br>Thanks,<br><br>Matt<br><br>