2011/11/23 Paul Cowan <span dir="ltr"><<a href="mailto:dagda1@scotalt.net">dagda1@scotalt.net</a>></span><br><div class="gmail_quote"><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">
<div>The problem is that messages are not sent until the all the messages in the iteration have been published.<br><br>That is after the iteration in the (0..5) loop has finished then all the messages are published.</div>
</blockquote></div><br>amqp gem is event-driven and care needs to be taken to not block the event loop. You can use EventMachine.defer<div>for processing of each message, then it will be executed in a thread pool. Remember, however, that sharing channels between</div>
<div>threads is a no-no so you will have to use a separate channel for publishing responses. It may potentially negate all the</div><div>benefits of publishing messages concurrently.<br>-- <br>MK<br><br><a href="http://github.com/michaelklishin" target="_blank">http://github.com/michaelklishin</a><br>
<a href="http://twitter.com/michaelklishin" target="_blank">http://twitter.com/michaelklishin</a><br><br>
</div>