Raj,<br><br><div class="gmail_quote">On 27 May 2011 09:24, Emile Joubert <span dir="ltr">&lt;<a href="mailto:emile@rabbitmq.com">emile@rabbitmq.com</a>&gt;</span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">

Hi,<div><div></div><div class="h5"><br>
<br>
On 26/05/11 19:05, Rajarshi Chakravarty wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Hi,<br>
<br>
Can anyone post an example of a Producer program in Java that creates a<br>
connection to a queue and keeps it open infinitely?<br>
<br>
My requirement is to listen to a port and whenever data comes to it,<br>
send it to a Rabbit queue.<br>
<br>
There should be some recovery mechanism like if the connection gets<br>
broken, the program should attempt a reconnect.<br>
</blockquote>
<br></div></div>
It should be possible to construct a solution using the Java message patterns library, which implements reconnection logic:<br>
<br>
<a href="http://hg.rabbitmq.com/rabbitmq-java-messagepatterns/" target="_blank">http://hg.rabbitmq.com/rabbitmq-java-messagepatterns/</a><br>
<br>
<br>
-Emile<br><br></blockquote><div><br></div><div>You may also want to take a look at this:</div><div><a href="https://github.com/joshdevins/rabbitmq-ha-client">https://github.com/joshdevins/rabbitmq-ha-client</a></div><div>

 </div><div>Jim</div><div><br></div></div>