activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <Sheetal.Kulka...@sungard.com>
Subject RE: ActiveMQ trying to reconnect to Random TCP port periodically
Date Thu, 06 Aug 2009 09:08:07 GMT
ActiveMQ on Linux gives error something like this on ActiveMQ console:

DEBUG log                            - EXCEPTION
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcher.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:233)
        at sun.nio.ch.IOUtil.read(IOUtil.java:206)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:207)
        at org.mortbay.io.nio.ChannelEndPoint.fill(ChannelEndPoint.java:128)
        at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:282)
        at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:205)
        at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:380)
        at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:395)
        at org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:450)
DEBUG log                            - EOF
DEBUG WireFormatNegotiator           - Sending: WireFormatInfo { version=3, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG Connection:6                   - SENDING: WireFormatInfo { version=3, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG TransportConnection            - stop() called in the middle of start(). Delaying...
DEBUG TransportConnection            - Calling the delayed stop()
DEBUG Connection:6                   - RECEIVED Exception: java.net.SocketException: Connection
reset
java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(SocketInputStream.java:168)
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(DataInputStream.java:353)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
        at java.lang.Thread.run(Thread.java:595)
DEBUG TransportConnection            - Stopping connection: /10.254.81.51:36717
DEBUG TcpTransport                   - Stopping transport tcp:///10.254.81.51:36717
DEBUG TransportConnection            - Stopped transport: /10.254.81.51:36717
DEBUG TransportConnection            - Connection Stopped: /10.254.81.51:36717
ERROR TransportConnector             - Could not accept connection : Connection reset
DEBUG TransportConnector             - Reason: Connection reset
java.net.SocketException: Connection reset
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:96)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115)
        at java.io.DataOutputStream.flush(DataOutputStream.java:106)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:167)
        at org.apache.activemq.transport.TransportLogger.oneway(TransportLogger.java:104)
        at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:233)
        at org.apache.activemq.transport.WireFormatNegotiator.sendWireFormat(WireFormatNegotiator.java:160)
        at org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:79)
        at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:57)
        at org.apache.activemq.broker.TransportConnection.start(TransportConnection.java:873)
        at org.apache.activemq.broker.TransportConnector$1$1.run(TransportConnector.java:213)
DEBUG AMQPersistenceAdapter          - dataFilesInProgress.values: (0) []
DEBUG AMQPersistenceAdapter          - lastDataFile: 1
DEBUG AsyncDataManager               - lastFileId=0, purgeList: (0) []
DEBUG AMQPersistenceAdapter          - Checkpoint started.
DEBUG AMQPersistenceAdapter          - Checkpoint done.
DEBUG AMQPersistenceAdapter          - dataFilesInProgress.values: (0) []
DEBUG AMQPersistenceAdapter          - lastDataFile: 1
DEBUG AsyncDataManager               - lastFileId=0, purgeList: (0) []
DEBUG AMQPersistenceAdapter          - Checkpoint started.
DEBUG AMQPersistenceAdapter          - Checkpoint done.
DEBUG AMQPersistenceAdapter          - Checkpoint started.
DEBUG AMQPersistenceAdapter          - Checkpoint done.
DEBUG AMQPersistenceAdapter          - dataFilesInProgress.values: (0) []


Can anyone comment on this?
Why activeMQ is trying to send messages and to whom does it send?
Mime
View raw message