<div dir="ltr">well , thank you for your quick response. <div><div>Well, it seemed fine when I tried to do it all in my local computer (two apps and rabbit)</div><div>but when I upgraded the clients in the production environment (whoops) the clients threw the following exception: </div>
<div>(side note: I did not change any property (socket,port etc ) in the client side. so i am guessing firewall is not an option because everything worked with the former version of rabbit - 1.7.0. )</div><div><br></div>
<div><div>com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.net.SocketException: Connection reset</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:588)</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:454)</div><div>Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.net.SocketException: Connection reset</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>... 2 more</div><div>Caused by: java.net.SocketException: Connection reset</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>at java.net.SocketInputStream.read(Unknown Source)</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>at java.io.BufferedInputStream.fill(Unknown Source)</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>at java.io.BufferedInputStream.read(Unknown Source)</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>at java.io.DataInputStream.readUnsignedByte(Unknown Source)</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:117)</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:151)</div><div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:379)</div>
<div><span class="Apple-tab-span" style="white-space:pre"> </span>at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:420)</div></div><div><br></div><div>Thank you <br><br><div class="gmail_quote">On Fri, Feb 25, 2011 at 1:46 PM, Matthias Radestock <span dir="ltr"><<a href="mailto:matthias@rabbitmq.com">matthias@rabbitmq.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">On 24/02/11 15:48, mysurf mail wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
What I basically see is that we start listening on the receiving<br>
app (subscriber) as follows:<br>
<br>
boolean durable = false;<br>
final boolean mandatory = true;<br>
final boolean immediate = true;<br>
channel.exchangeDeclare(exchangeName, "direct", durable,<br>
mandatory, immediate, new HashMap<String, Object>());<br>
channel.queueDeclare(queueName, durable);<br>
channel.queueBind(queueName, exchangeName, routingKey);<br>
<br>
boolean noAck = true;<br>
queueingConsumer = new QueueingConsumer(channel);<br>
channel.basicConsume(queueName, noAck, queueingConsumer);<br>
</blockquote>
<br></div>
So the client is consuming in noAck/autoAck mode, which means it *must not* basicAck the messages. The error<div class="im"><br>
<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
> reply-code=406,reply-text=PRECONDITION_FAILED - unknown delivery tag<br>
> 1,class-id=60,method-id=80),null,""}<br>
</blockquote>
<br></div>
is most likely due it doing that.<br>
<br>
Regards,<br><font color="#888888">
<br>
Matthias.<br>
</font></blockquote></div><br></div></div></div>