I have a daemon process which uses a Tornado IO loop for event processing and the pika/TornadoConnection class<div>for interacting with Rabbit.</div><div><br></div><div>My processing loop looks like:</div><div><br></div><div>&nbsp; -wait to receive a Rabbit message (ioloop.start())</div><div>&nbsp; -on message:</div><div>&nbsp; &nbsp; - loop</div><div>&nbsp; &nbsp; &nbsp; &nbsp;- do some work</div><div>&nbsp; &nbsp; &nbsp; &nbsp;- publish a status message (like "work item #1 complete")</div><div><br></div><div>My problem is that in the case there is lots of work to do, then messages published inside the "do some work"</div><div>loop&nbsp;don't seem to get sent until processing is finished and returns&nbsp;</div><div>to the ioloop. Is there some way to make those messages be published immediately, like a flush? Or is there</div><div>a different pattern I should use to ensure timely publishing?</div><div><br></div><div>thanks</div><div><br></div>