<div dir="ltr"><br>Hi,�<br><div class="gmail_quote"><div dir="ltr"><div>I ran the multicast main . from the computer with the good connection it seemed to work.�</div><div>from the computer with the bad connection - it seemed to not work.</div>
<div><br></div><div>I was seconds away from taking this to the IT , but then I remembered that both computes run the RabbitMQ client 1.7.0 successfully .</div>
<div><br></div><div>Maybe you can tell me what changed in the implementation of the 2.3.1 or the erlang??�</div><div><br></div><div>I am adding the output file for the multicast. it has outputs from both computers.�</div>
<div><br></div><div>I really appreciate your help. I hope this will resolve soon as we are in a mess currently in the production system.</div><div>Thanks.</div><div><div></div><div class="h5"><div>�<br><br><div class="gmail_quote">
On Wed, Mar 2, 2011 at 1:01 PM, Emile Joubert <span dir="ltr"><<a href="mailto:emile@rabbitmq.com" target="_blank">emile@rabbitmq.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><br>
Hi,<br>
<br>
It is very strange to see an AMQP connection work perfectly via the tracer but fail without it.<br>
<br>
(Does the broker listen on the same port in both cases? If not, does the underlying network treat both ports the same?)<br>
<br>
Can you replicate these results with any of the built-in Java examples that are provided with RabbitMQ? I would suggest using the MulticastMain tool with and without the Tracer. This will eliminate the possibility of AMQP protocol errors causing the problem.<br>
<br>
> DataInputStream.readUnsignedByte()<br>
This is not the cause of the problem. It probably just means that the underlying connection has been forcefully closed.<div><br>
<br>
> It happens only from certain computers.<br></div>
Do these computers have anything in common with each other that they do not have in common with the computers that don't produce errors?<br><font color="#888888">
<br>
<br>
<br>
-Emile</font><div><br>
<br>
<br>
On 02/03/11 09:41, mysurf mail wrote:<br>
</div><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div>
<br>
We debugged the tracer and saw that it uses java.net.socket. The<br>
connection was ok through the tracer.<br>
Now, �we closed the tracer and connected directly to the rabbit.<br>
We �attached the source and debugged factory.newconnmection() we saw the<br>
exception occured in DataInputStream.readUnsignedByte() . (it throws an<br>
EOFException when ch<0) .<br>
any ideas?<br>
<br>
On Wed, Mar 2, 2011 at 9:41 AM, mysurf mail <<a href="mailto:stammailbox@gmail.com" target="_blank">stammailbox@gmail.com</a><br></div><div><div></div><div>
<mailto:<a href="mailto:stammailbox@gmail.com" target="_blank">stammailbox@gmail.com</a>>> wrote:<br>
<br>
� �Flash News :<br>
� �I am sorry to bother you a lot this morning . But I have an<br>
� �interesting finding<br>
� �When I activate my client with the tracer - it connects well to the<br>
� �rabbitmq server .<br>
� �when I connect directly - it throws that exception .<br>
<br>
� �So maybe my problem is with the connection string ?<br>
� �here it is - I only replace the �ip and port<br>
� �BasicChannel(Username, Password, VirtualHost, BrokerIp, BrokerPort,<br>
� �Heartbeat);<br>
� �BasicChannel(Username, Password, VirtualHost, "127.0.0.1",5672,<br>
� �Heartbeat);<br>
<br>
� �and my ctor is<br>
<br>
� �public BasicChannel(final String username, final String password, final String virtualHost, final String brokerIp, final int brokerPort, int heartbeat) {<br>
� � � � � � ConnectionFactory factory = new ConnectionFactory();<br>
� � � � � � factory.setUsername(username);<br>
� � � � � � factory.setPassword(password);<br>
� � � � � � factory.setVirtualHost(virtualHost);<br>
� � � � � � factory.setRequestedHeartbeat(heartbeat);<br>
� � � � � � factory.setHost(brokerIp);<br>
� � � � � � factory.setPort(brokerPort);<br>
<br>
� � � � � � connection = null;<br>
� � � � � � try {<br>
� � � � � � � � connection = factory.newConnection();<br>
� � � � � � } catch (IOException e) {<br>
� � � � � � � � throw new PlatformException("could not create connection", e);<br>
� � � � � � }<br>
<br>
<br>
<br>
� �Thanks<br>
</div></div></blockquote>
</blockquote></div><br></div></div></div></div>
</div><br></div>