[activemq-user] Failed to add client ...

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

[activemq-user] Failed to add client ...

SridharK
We have a legacy consumer application that we are trying to test with
ActiveMQ broker.

It is not clear why the broker disconnects the consumer. Any help is
appreciated (I have included
both the broker and consumer stack traces below). Thanks !

Broker stack trace:

2005-11-21 18:57:31,010 [mon.com:61616 <http://on.com:61616>] DEBUG
BrokerClientImpl - brokerConnectorConnector client initialized
2005-11-21 18:57:31,010 [mon.com:61616 <http://on.com:61616>] DEBUG
BrokerConnectorImpl - Starting new client: brokerConnector-client:(3284130\
8) : TcpTransportChannel: Socket[addr=/127.0.0.1,port=38391,localport=61616]
2005-11-21 18:57:41,014 [mon.com:61616 <http://on.com:61616>] ERROR
BrokerConnectorImpl - Failed to add client due to: javax.jms.JMSException:\
start failed: Read timed out
javax.jms.JMSException: start failed: Read timed out
at org.activemq.transport.tcp.TcpTransportChannel.start(
TcpTransportChannel.java:199)
at org.activemq.broker.impl.BrokerConnectorImpl.addClient(
BrokerConnectorImpl.java:318)
at org.activemq.transport.TransportServerChannelSupport.addClient(
TransportServerChannelSupport.java:98)
at org.activemq.transport.tcp.TcpTransportServerChannel.run(
TcpTransportServerChannel.java:158)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.net.SocketTimeoutException: Read timed out
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:129)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
at java.io.FilterInputStream.read(FilterInputStream.java:66)
at org.activemq.io.WireFormatLoader.getWireFormat(WireFormatLoader.java:67)
at org.activemq.transport.tcp.TcpTransportChannel.readWireFormat(
TcpTransportChannel.java:208)
at org.activemq.transport.tcp.TcpTransportChannel.start(
TcpTransportChannel.java:178)
... 4 more


Consumer trace ...

Tue Nov 22 02:57:41 2005 GMT org.activemq.ActiveMQConnection: channel status
changed: Channel: TcpTransportChannel:
Socket[addr=localhost/127.0.0.1,port=61616,localport=38391] has connected
Tue Nov 22 02:58:09 2005 GMT (TcpTransportChannel:
Socket[addr=localhost/127.0.0.1,port=61616,localport=38391])
org.activemq.ActiveMQConnection: channel status changed: Channel:
TcpTransportChannel:
Socket[addr=localhost/127.0.0.1,port=61616,localport=38391] has disconnected
Tue Nov 22 02:58:09 2005 GMT (TcpTransportChannel:
Socket[addr=localhost/127.0.0.1,port=61616,localport=38391])
org.activemq.util.JMSExceptionHelper: Error reading socket:
java.net.SocketException: Connection reset { java.net.SocketException:
Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:168)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
at java.io.DataInputStream.readByte(DataInputStream.java:241)
at org.activemq.io.AbstractWireFormat.readPacket(AbstractWireFormat.java
:230)
at org.activemq.transport.tcp.TcpTransportChannel.run(
TcpTransportChannel.java:313)
at java.lang.Thread.run(Thread.java:595) }



--
Please use "Reply-To" address, your email client should pick this
Reply | Threaded
Open this post in threaded view
|

Re: [activemq-user] Failed to add client ...

James Strachan-2
On 22 Nov 2005, at 03:24, Sridhar Komandur wrote:
> We have a legacy consumer application that we are trying to test with
> ActiveMQ broker.
>
> It is not clear why the broker disconnects the consumer. Any help is
> appreciated (I have included
> both the broker and consumer stack traces below). Thanks !

Its looking like a TCP timeout between the connection being started  
and the connection.start() method being called. Its a feature of 3.x  
that a JMS client has to start the connection fairly quickly  
otherwise the transport times out (its a bit of a bug as the  timeout  
occurs while trying to perform protocol version negotiation; the TCP  
transport handles timeouts much better once the connection is  
established).

This issue is resolved in 4.x if that helps.

James

> Broker stack trace:
>
> 2005-11-21 18:57:31,010 [mon.com:61616 <http://on.com:61616>] DEBUG
> BrokerClientImpl - brokerConnectorConnector client initialized
> 2005-11-21 18:57:31,010 [mon.com:61616 <http://on.com:61616>] DEBUG
> BrokerConnectorImpl - Starting new client: brokerConnector-client:
> (3284130\
> 8) : TcpTransportChannel: Socket[addr=/
> 127.0.0.1,port=38391,localport=61616]
> 2005-11-21 18:57:41,014 [mon.com:61616 <http://on.com:61616>] ERROR
> BrokerConnectorImpl - Failed to add client due to:  
> javax.jms.JMSException:\
> start failed: Read timed out
> javax.jms.JMSException: start failed: Read timed out
> at org.activemq.transport.tcp.TcpTransportChannel.start(
> TcpTransportChannel.java:199)
> at org.activemq.broker.impl.BrokerConnectorImpl.addClient(
> BrokerConnectorImpl.java:318)
> at org.activemq.transport.TransportServerChannelSupport.addClient(
> TransportServerChannelSupport.java:98)
> at org.activemq.transport.tcp.TcpTransportServerChannel.run(
> TcpTransportServerChannel.java:158)
> at java.lang.Thread.run(Thread.java:595)
> Caused by: java.net.SocketTimeoutException: Read timed out
> at java.net.SocketInputStream.socketRead0(Native Method)
> at java.net.SocketInputStream.read(SocketInputStream.java:129)
> at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
> at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
> at java.io.FilterInputStream.read(FilterInputStream.java:66)
> at org.activemq.io.WireFormatLoader.getWireFormat
> (WireFormatLoader.java:67)
> at org.activemq.transport.tcp.TcpTransportChannel.readWireFormat(
> TcpTransportChannel.java:208)
> at org.activemq.transport.tcp.TcpTransportChannel.start(
> TcpTransportChannel.java:178)
> ... 4 more
>
>
> Consumer trace ...
>
> Tue Nov 22 02:57:41 2005 GMT org.activemq.ActiveMQConnection:  
> channel status
> changed: Channel: TcpTransportChannel:
> Socket[addr=localhost/127.0.0.1,port=61616,localport=38391] has  
> connected
> Tue Nov 22 02:58:09 2005 GMT (TcpTransportChannel:
> Socket[addr=localhost/127.0.0.1,port=61616,localport=38391])
> org.activemq.ActiveMQConnection: channel status changed: Channel:
> TcpTransportChannel:
> Socket[addr=localhost/127.0.0.1,port=61616,localport=38391] has  
> disconnected
> Tue Nov 22 02:58:09 2005 GMT (TcpTransportChannel:
> Socket[addr=localhost/127.0.0.1,port=61616,localport=38391])
> org.activemq.util.JMSExceptionHelper: Error reading socket:
> java.net.SocketException: Connection reset { java.net.SocketException:
> Connection reset
> at java.net.SocketInputStream.read(SocketInputStream.java:168)
> at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
> at java.io.BufferedInputStream.read(BufferedInputStream.java:235)
> at java.io.DataInputStream.readByte(DataInputStream.java:241)
> at org.activemq.io.AbstractWireFormat.readPacket
> (AbstractWireFormat.java
> :230)
> at org.activemq.transport.tcp.TcpTransportChannel.run(
> TcpTransportChannel.java:313)
> at java.lang.Thread.run(Thread.java:595) }
>
>
>
> --
> Please use "Reply-To" address, your email client should pick this


James
-------
http://radio.weblogs.com/0112098/