git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Stale connection hanging at broker during consumer crash


I am getting this exception on broker side when consumer crashes. 
Is there anyway to close the connection completely on broker side.?

2018-10-01T09:50:27.589+0200 [ActiveMQ Transport: ssl:///x.x.x.x:42188]
DEBUG o.a.a.t.logwriters.DefaultLogWriter:65 logReceivedException RECEIVED
Exception: java.io.EOFException
java.io.EOFException: null
        at java.io.DataInputStream.readInt(DataInputStream.java:392)
~[na:1.8.0_152]
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
~[activemq-client-5.14.0.jar:5.14.0]
        at java.lang.Thread.run(Thread.java:748) [na:1.8.0_152]
2018-10-01T09:50:27.592+0200 [ActiveMQ Transport: ssl:///x.x.x.x:42188]
DEBUG o.a.a.broker.TransportConnection:238 serviceTransportException
Transport Connection to: tcp://x.x.x.x:42188 failed: java.io.EOFException
java.io.EOFException: null
        at java.io.DataInputStream.readInt(DataInputStream.java:392)
~[na:1.8.0_152]
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)
~[activemq-client-5.14.0.jar:5.14.0]
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
~[activemq-client-5.14.0.jar:5.14.0]
        at java.lang.Thread.run(Thread.java:748) [na:1.8.0_152]




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html