Michael, something like this would be fantastic (and less code to maintain on my part). any chance of it getting into the RC14?<br><br><div class="gmail_quote">On 8 July 2011 15:41, Michael Klishin <span dir="ltr"><<a href="mailto:michael.s.klishin@gmail.com">michael.s.klishin@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;"><div class="im">2011/7/8 Michael Nacos <span dir="ltr"><<a href="mailto:m.nacos@gmail.com" target="_blank">m.nacos@gmail.com</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">
so, what's currently the best way to publish messages consumed from one queue into another with the amqp gem? This is quite important in processing scenaria when no messages may be lost.</blockquote></div><br></div>Michael,<br>
<br>Does this piece of code look like what you would like to have? An entity that consumes messages from one queue and republishes them safely into another queue, with a way to transform the message?<br><br><a href="https://gist.github.com/1071983" target="_blank">https://gist.github.com/1071983</a><br>
<br>This imaginary AMQP::Rebroadcaster is not that difficult to design and add to the amqp gem for RC14 (will be out in a few weeks after<br>some more testing with real world apps).<div><div></div><div class="h5"><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></div></blockquote></div><br>