activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: ActiveMQ trying to reconnect to Random TCP port periodically
Date Fri, 07 Aug 2009 08:50:08 GMT
If this is still a problem for you, one path that may help determine the
culprit would be to compile a version of WireFormatNegotiator with the
following change and place if first on the classpath of your application or
start script.

The change will produce a stacktrace via the exception when it sends the
initial wire format info which should point back to the initiator.

Index:
activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
===================================================================
---
activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
(revision 801557)
+++
activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
(working copy)
@@ -79,7 +79,7 @@
         try {
             WireFormatInfo info = wireFormat.getPreferedWireFormatInfo();
             if (LOG.isDebugEnabled()) {
-                LOG.debug("Sending: " + info);
+                LOG.debug("Sending: " + info, new
RuntimeException("DumpOnSendWireFormat"));
             }
             sendWireFormat(info);
         } finally {


2009/8/7 <Sheetal.Kulkarni@sungard.com>

> Hi,
>
> One more input for the same error:
>
> It is trying to send the below message to some tcp connection.
> To whom does it send the message?
>
>
> 2009-08-07 03:58:44,394 [254.81.51:37781] 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]}
> 2009-08-07 03:58:44,394 [254.81.51:37781] DEBUG Connection:85
> - 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]}
>
>
> P Think before you print
> -----Original Message-----
> From: Gary Tully [mailto:gary.tully@gmail.com]
> Sent: Thursday, August 06, 2009 2:58 PM
> To: dev@activemq.apache.org
> Subject: Re: ActiveMQ trying to reconnect to Random TCP port
> periodically
>
> that looks like an openwire connect attempt to the http endpoint and
> negotiation is failing. Can you post your activemq.xml file. One
> possibility
> is the embedded camel context which will do periodic retries (polls) but
> the
> ActiveMQConnection factory uri must be misconfigured in that case.
>
>
> 2009/8/6 <Sheetal.Kulkarni@sungard.com>
>
> > 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.ja
> va: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(TcpBuffere
> dInputStream.java:50)
> >        at
> >
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuffere
> dInputStream.java:58)
> >        at java.io.DataInputStream.readInt(DataInputStream.java:353)
> >        at
> >
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.jav
> a:269)
> >        at
> >
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.
> java:210)
> >        at
> >
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:2
> 02)
> >        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(TcpBuffe
> redOutputStream.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.jav
> a:104)
> >        at
> >
> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor
> .java:233)
> >        at
> >
> org.apache.activemq.transport.WireFormatNegotiator.sendWireFormat(WireFo
> rmatNegotiator.java:160)
> >        at
> >
> org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegot
> iator.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?
> >
>
>
>
> --
> http://blog.garytully.com
>
> Open Source Integration
> http://fusesource.com
>
>


-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message