activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hunan <nan...@xa.vixtel.com>
Subject our program reconnect repeatly due to java.net.SocketException: Connection reset
Date Thu, 23 Jun 2011 01:32:35 GMT
we use activemq 5.3.0 , our client program reconnect repeatly due to "
java.net.SocketException: Connection reset" on that computer , but normal on
other computers , the concrete logs is:

[DEBUG] 2011-06-17 21:11:39,343   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
 command id: 1
[DEBUG] 2011-06-17 21:11:39,359   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:11:39,359   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:11:39,375   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
 command id: 2
[DEBUG] 2011-06-17 21:13:39,281   []  
org.apache.activemq.transport.tcp.TcpTran
sport.doStop(TcpTransport.java:458)             Stopping transport
tcp:///222.12
7.223.137:61616
[WARN ] 2011-06-17 21:13:39,281   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:206)
Transport failed to
tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration
=0 , attempting to automatically reconnect due to: java.net.SocketException:
Con
nection reset
[DEBUG] 2011-06-17 21:13:39,281   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:207)
Transport failed with the following exception:
java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(Unknown Source)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuff
eredInputStream.java:50)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuff
eredInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
java:272)
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
rt.java:210)
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
a:202)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
185)
        at java.lang.Thread.run(Unknown Source)
[DEBUG] 2011-06-17 21:13:39,296   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.getConnectList(FailoverTransport.java:593)             
urlList
connectionList:[tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0]
[DEBUG] 2011-06-17 21:13:39,312   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:712)         Attempting
conne
ct to: tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:13:39,328   []  
org.apache.activemq.transport.WireFormatN
egotiator.sendWireFormat(WireFormatNegotiator.java:82)          Sending:
WireFor
matInfo { version=5, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpN
oDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactiv
ityDurationInitalDelay=10000, MaxInactivityDuration=0, CacheEnabled=true},
magic
=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:13:39,343   []  
org.apache.activemq.transport.tcp.TcpTran
sport.run(TcpTransport.java:181)                TCP consumer thread for
tcp:///2
22.127.223.137:61616 starting
[DEBUG] 2011-06-17 21:13:39,375   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:118)              Received
WireFor
mat: WireFormatInfo { version=5, properties={TightEncodingEnabled=true,
CacheSiz
e=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true
, MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=0,
CacheEnabled=
true}, magic=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:13:39,375   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:125)             
tcp:///222.127.2
23.137:61616 before negotiation: OpenWireFormat{version=5,
cacheEnabled=false, s
tackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:13:39,375   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:140)             
tcp:///222.127.2
23.137:61616 after negotiation: OpenWireFormat{version=5, cacheEnabled=true,
sta
ckTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:13:39,390   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)           
restore,
 replay: ActiveMQObjectMessage {commandId = 343, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:18:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:18:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315795218, timestamp = 1308315495218, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://NETVISTA.GUI.
SYNC63224970514165, persistent = true, type = null, priority = 4, groupID =
null
, groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null,
 content = org.apache.activemq.util.ByteSequence@16ea3c2,
marshalledProperties =
 org.apache.activemq.util.ByteSequence@1e34309, dataStructure = null,
redelivery
Counter = 0, size = 0, properties = {MESSAGE_SELECTOR=1308315495203,
COMMOND_TYP
E=0}, readOnlyProperties = true, readOnlyBody = true, droppable = false}
[DEBUG] 2011-06-17 21:13:39,406   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)           
restore,
 replay: ActiveMQObjectMessage {commandId = 349, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:19:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:19:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315811390, timestamp = 1308315511390, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent
= tr
ue, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumer
Id = null, compressed = false, userID = null, content =
org.apache.activemq.util
.ByteSequence@e64834, marshalledProperties =
org.apache.activemq.util.ByteSequen
ce@146101f, dataStructure = null, redeliveryCounter = 0, size = 0,
properties =
{SESSION_ID=63224970514165}, readOnlyProperties = true, readOnlyBody = true,
dro
ppable = false}
[DEBUG] 2011-06-17 21:13:39,421   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:721)         Connection
estab
lished
[INFO ] 2011-06-17 21:13:39,421   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:747)         Successfully
rec
onnected to tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:13:39,437   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
 command id: 1
[DEBUG] 2011-06-17 21:13:39,437   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:13:39,453   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:13:39,453   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
 command id: 2
[DEBUG] 2011-06-17 21:15:39,046   []  
org.apache.activemq.transport.tcp.TcpTran
sport.doStop(TcpTransport.java:458)             Stopping transport
tcp:///222.12
7.223.137:61616
[WARN ] 2011-06-17 21:15:39,046   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:206)
Transport failed to
tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration
=0 , attempting to automatically reconnect due to: java.net.SocketException:
Con
nection reset
[DEBUG] 2011-06-17 21:15:39,062   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.handleTransportFailure(FailoverTransport.java:207)
Transport failed with the following exception:
java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(Unknown Source)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuff
eredInputStream.java:50)
        at
org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuff
eredInputStream.java:58)
        at java.io.DataInputStream.readInt(Unknown Source)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
java:272)
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
rt.java:210)
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
a:202)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
185)
        at java.lang.Thread.run(Unknown Source)
[DEBUG] 2011-06-17 21:15:39,078   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.getConnectList(FailoverTransport.java:593)             
urlList
connectionList:[tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0]
[DEBUG] 2011-06-17 21:15:39,078   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:712)         Attempting
conne
ct to: tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:15:39,109   []  
org.apache.activemq.transport.WireFormatN
egotiator.sendWireFormat(WireFormatNegotiator.java:82)          Sending:
WireFor
matInfo { version=5, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpN
oDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactiv
ityDurationInitalDelay=10000, MaxInactivityDuration=0, CacheEnabled=true},
magic
=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:15:39,109   []  
org.apache.activemq.transport.tcp.TcpTran
sport.run(TcpTransport.java:181)                TCP consumer thread for
tcp:///2
22.127.223.137:61616 starting
[DEBUG] 2011-06-17 21:15:39,125   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:118)              Received
WireFor
mat: WireFormatInfo { version=5, properties={TightEncodingEnabled=true,
CacheSiz
e=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true
, MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=0,
CacheEnabled=
true}, magic=[A,c,t,i,v,e,M,Q]}
[DEBUG] 2011-06-17 21:15:39,140   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:125)             
tcp:///222.127.2
23.137:61616 before negotiation: OpenWireFormat{version=5,
cacheEnabled=false, s
tackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:15:39,140   []  
org.apache.activemq.transport.WireFormatN
egotiator.negociate(WireFormatNegotiator.java:140)             
tcp:///222.127.2
23.137:61616 after negotiation: OpenWireFormat{version=5, cacheEnabled=true,
sta
ckTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
[DEBUG] 2011-06-17 21:15:39,140   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)           
restore,
 replay: ActiveMQObjectMessage {commandId = 343, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:18:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:18:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315795218, timestamp = 1308315495218, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo =
queue://NETVISTA.GUI.
SYNC63224970514165, persistent = true, type = null, priority = 4, groupID =
null
, groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null,
 content = org.apache.activemq.util.ByteSequence@16ea3c2,
marshalledProperties =
 org.apache.activemq.util.ByteSequence@1e34309, dataStructure = null,
redelivery
Counter = 0, size = 0, properties = {MESSAGE_SELECTOR=1308315495203,
COMMOND_TYP
E=0}, readOnlyProperties = true, readOnlyBody = true, droppable = false}
[DEBUG] 2011-06-17 21:15:39,156   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.restoreTransport(FailoverTransport.java:635)           
restore,
 replay: ActiveMQObjectMessage {commandId = 349, responseRequired = true,
messag
eId = ID:gdi030006-1660-1308315269437-0:0:19:1:1, originalDestination =
null, or
iginalTransactionId = null, producerId =
ID:gdi030006-1660-1308315269437-0:0:19:
1, destination = queue://NETVISTA.GUI.REPLY.63224970514165, transactionId =
null
, expiration = 1308315811390, timestamp = 1308315511390, arrival = 0,
brokerInTi
me = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent
= tr
ue, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumer
Id = null, compressed = false, userID = null, content =
org.apache.activemq.util
.ByteSequence@e64834, marshalledProperties =
org.apache.activemq.util.ByteSequen
ce@146101f, dataStructure = null, redeliveryCounter = 0, size = 0,
properties =
{SESSION_ID=63224970514165}, readOnlyProperties = true, readOnlyBody = true,
dro
ppable = false}
[DEBUG] 2011-06-17 21:15:39,171   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:721)         Connection
estab
lished
[INFO ] 2011-06-17 21:15:39,187   []  
org.apache.activemq.transport.failover.Fa
iloverTransport.doReconnect(FailoverTransport.java:747)         Successfully
rec
onnected to tcp://222.127.223.137:61616?wireFormat.maxInactivityDuration=0
[DEBUG] 2011-06-17 21:15:39,187   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
1}}for
 command id: 1
[DEBUG] 2011-06-17 21:15:39,203   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
28}}fo
r command id: 28
[DEBUG] 2011-06-17 21:15:39,203   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
70}}fo
r command id: 70
[DEBUG] 2011-06-17 21:15:39,218   []  
org.apache.activemq.transport.ResponseCor
relator.onCommand(ResponseCorrelator.java:105)          Received unexpected
resp
onse: {Response {commandId = 0, responseRequired = false, correlationId =
2}}for
 command id: 2


--
View this message in context: http://activemq.2283324.n4.nabble.com/our-program-reconnect-repeatly-due-to-java-net-SocketException-Connection-reset-tp3618719p3618719.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message