activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: DemandForwardingBridge - Ignoring sub ConsumerInf
Date Wed, 19 Jun 2013 14:03:09 GMT
Hi,

it looks like it's indeed a case of unstable physical connection between
brokers. The message

Channel was inactive for too long.
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.

means that socket is basically dead. I'd suggest you do some investigation
on a network connection between brokers.

Regards
--
Dejan Bosanac
----------------------
Red Hat, Inc.
FuseSource is now part of Red Hat
dbosanac@redhat.com
Twitter: @dejanb
Blog: http://sensatic.net
ActiveMQ in Action: http://www.manning.com/snyder/


On Wed, Jun 19, 2013 at 1:50 PM, mmg <manjusha.gole@gmail.com> wrote:

> Hi Dejan,
>
> Now we are not receiving any messages between these two brokers. We can see
> following exceptions and messages in Active MQ logs (there is one hr time
> difference between these two hosts). Could you please let us know the
> reason
> for these exceptions and what needs to be done to get over this issue?
>
>
> logs on host A :
>
>
> 2013-06-13 02:00:09,200 [127.0.0.1:41924] DEBUG Transport
> - Transport failed: java.io.EOFException
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
>
> 2013-06-13 03:00:10,196 [127.0.0.1:50816] DEBUG Transport
> - Transport failed: java.io.EOFException
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
>
> 2013-06-13 03:09:41,970 [iveMQ Scheduler] WARN  DemandForwardingBridge
> - Outbound transport to avayaiq1cr.cam.wal-mart.com-broker interrupted ...
> 2013-06-13 03:09:41,971 [iveMQ Scheduler] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:09:41,971 [ker: 1376681299] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://10.77.225.90:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 03:09:42,060 [77.225.90:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:09:42,060 [ker: 1376681299] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:09:42,498 [77.225.90:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:09:42,498 [77.225.90:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiq1cr.cam.wal-mart.com/10.77.225.90:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 03:09:42,498 [77.225.90:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiq1cr.cam.wal-mart.com/10.77.225.90:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 03:09:42,498 [ker: 1376681299] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 03:09:42,498 [ker: 1376681299] INFO  DemandForwardingBridge
> - Outbound transport to avayaiq1cr.cam.wal-mart.com-broker resumed
> 2013-06-13 03:09:42,499 [77.225.90:61617] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> java.net.SocketException: Socket closed
>         at java.net.SocketInputStream.socketRead0(Native Method)
>         at java.net.SocketInputStream.read(Unknown Source)
>         at com.sun.net.ssl.internal.ssl.InputRecord.readFully(Unknown
> Source)
>         at com.sun.net.ssl.internal.ssl.InputRecord.read(Unknown Source)
>         at com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(Unknown
> Source)
>         at
> com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(Unknown
> Source)
>         at com.sun.net.ssl.internal.ssl.AppInputStream.read(Unknown Source)
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:09:42,499 [Thread-5       ] DEBUG FailoverTransport
> - Waiting for transport to reconnect.
> 2013-06-13 03:09:42,499 [ker: 1376681299] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://10.77.225.90:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 03:09:42,499 [77.225.90:61617] WARN  DemandForwardingBridge
> - Outbound transport to avayaiq1cr.cam.wal-mart.com-broker interrupted ...
> 2013-06-13 03:09:42,499 [77.225.90:61617] INFO  Service
> - Async error occurred: java.lang.IllegalStateException: Cannot lookup a
> connection that had not been registered:
> ID:avayaiqe1.ivr.wal-mart.com-47420-1369884669888-3:1
> java.lang.IllegalStateException: Cannot lookup a connection that had not
> been registered: ID:avayaiqe1.ivr.wal-mart.com-47420-1369884669888-3:1
>         at
>
> org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:241)
>         at
>
> org.apache.activemq.broker.AbstractConnection.processRemoveConnection(AbstractConnection.java:519)
>         at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:59)
>         at
>
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
>         at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>         at
>
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>         at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>         at
>
> org.apache.activemq.network.DemandForwardingBridgeSupport$2.transportInterupted(DemandForwardingBridgeSupport.java:138)
>         at
>
> org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
>         at
>
> org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:223)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport.access$300(FailoverTransport.java:53)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport$1.onException(FailoverTransport.java:111)
>         at
>
> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:120)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)
>         at
>
> org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:100)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:156)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:09:42,503 [her: 1344918164] WARN  DemandForwardingBridge
> - Unexpected local command: ConnectionError {commandId = 24,
> responseRequired = false, connectionId = null, exception =
> java.lang.IllegalStateException: Cannot lookup a connection that had not
> been registered: ID:avayaiqe1.ivr.wal-mart.com-47420-1369884669888-3:1}
> 2013-06-13 03:09:42,591 [ker: 1376681299] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:09:42,591 [77.225.90:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:09:43,024 [ker: 1376681299] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 03:09:43,024 [ker: 1376681299] INFO  DemandForwardingBridge
> - Outbound transport to avayaiq1cr.cam.wal-mart.com-broker resumed
> 2013-06-13 03:09:43,024 [77.225.90:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:09:43,024 [77.225.90:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiq1cr.cam.wal-mart.com/10.77.225.90:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 03:09:43,024 [77.225.90:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiq1cr.cam.wal-mart.com/10.77.225.90:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 03:09:43,114 [Thread-6       ] INFO  DemandForwardingBridge
> - Network connection between vm://avayaiqe1.ivr.wal-mart.com-broker#0 and
> ssl://
> 10.77.225.90:61617?wireFormat.maxInactivityDuration=600000(avayaiq1cr.cam.wal-mart.com-broker)
> has been established.
> 2013-06-13 03:10:43,213 [iveMQ Scheduler] DEBUG Transport
> - Transport failed: org.apache.activemq.transport.InactivityIOException:
> Channel was inactive for too long.
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:11:08,849 [-mart.com:61617] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:11:08,849 [77.225.90:39452] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:11:09,284 [77.225.90:39452] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:11:09,284 [77.225.90:39452] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:39452 before negotiation: OpenWireFormat{version=1,
> cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false,
> sizePrefixDisabled=false}
> 2013-06-13 03:11:09,284 [77.225.90:39452] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:39452 after negotiation: OpenWireFormat{version=1,
> cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
> sizePrefixDisabled=false}
> 2013-06-13 03:12:11,183 [eckpoint Worker] DEBUG JournalPersistenceAdapter
> - Checkpoint started.
>
>
>
> --------------------------
>
> 2013-06-13 03:51:09,286 [iveMQ Scheduler] DEBUG Transport
> - Transport failed: org.apache.activemq.transport.InactivityIOException:
> Channel was inactive for too long.
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:51:31,017 [77.225.90:37022] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:51:31,017 [-mart.com:61617] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:51:31,455 [77.225.90:37022] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:51:31,456 [77.225.90:37022] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37022 before negotiation: OpenWireFormat{version=1,
> cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false,
> sizePrefixDisabled=false}
> 2013-06-13 03:51:31,456 [77.225.90:37022] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37022 after negotiation: OpenWireFormat{version=1,
> cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
> sizePrefixDisabled=false}
> 2013-06-13 03:52:31,466 [77.225.90:37022] DEBUG Transport
> - Transport failed: java.io.EOFException
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:52:31,555 [77.225.90:37027] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:52:31,555 [-mart.com:61617] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:52:31,992 [77.225.90:37027] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:52:31,992 [77.225.90:37027] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37027 before negotiation: OpenWireFormat{version=1,
> cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false,
> sizePrefixDisabled=false}
> 2013-06-13 03:52:31,992 [77.225.90:37027] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37027 after negotiation: OpenWireFormat{version=1,
> cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
> sizePrefixDisabled=false}
> 2013-06-13 03:52:31,997 [cher: 872130173] DEBUG Transport
> - Transport failed: java.net.SocketException: Connection closed by remote
> host
> java.net.SocketException: Connection closed by remote host
>         at com.sun.net.ssl.internal.ssl.SSLSocketImpl.checkWrite(Unknown
> Source)
>         at com.sun.net.ssl.internal.ssl.AppOutputStream.write(Unknown
> Source)
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:108)
>         at java.io.DataOutputStream.flush(Unknown Source)
>         at
>
> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:125)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
>         at
>
> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:78)
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:77)
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>         at
>
> org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:211)
>         at
>
> org.apache.activemq.broker.AbstractConnection.processDispatch(AbstractConnection.java:581)
>         at
>
> org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnection.java:597)
>         at
>
> org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:87)
>         at
>
> org.apache.activemq.thread.DedicatedTaskRunner.access$000(DedicatedTaskRunner.java:24)
>         at
>
> org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:38)
> 2013-06-13 03:52:31,997 [77.225.90:37027] DEBUG Transport
> - Transport failed: java.io.EOFException
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 03:52:31,998 [77.225.90:37027] WARN  ManagedTransportConnection
> - Failed to unregister mbean:
>
> org.apache.activemq:BrokerName=avayaiqe1.ivr.wal-mart.com-broker,Type=Connection,ConnectorName=secured,Connection=NC_avayaiq1cr.cam.wal-mart.com-broker_outboundavayaiq1cr.cam.wal-mart.com-broker
> 2013-06-13 03:52:32,082 [-mart.com:61617] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:52:32,082 [77.225.90:37028] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 03:52:32,516 [77.225.90:37028] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 03:52:32,516 [77.225.90:37028] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37028 before negotiation: OpenWireFormat{version=1,
> cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false,
> sizePrefixDisabled=false}
> 2013-06-13 03:52:32,516 [77.225.90:37028] DEBUG WireFormatNegotiator
> - tcp:///10.77.225.90:37028 after negotiation: OpenWireFormat{version=1,
> cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true,
> sizePrefixDisabled=false}
> 2013-06-13 03:56:11,183 [eckpoint Worker] DEBUG JournalPersistenceAdapter
> - Checkpoint started.
>
>
> ---------------------------------
> 2013-06-13 04:23:02,518 [iveMQ Scheduler] DEBUG Transport
> - Transport failed: org.apache.activemq.transport.InactivityIOException:
> Channel was inactive for too long.
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 04:23:11,183 [eckpoint Worker] DEBUG JournalPersistenceAdapter
> - Checkpoint started.
>
>
>
>
> On Host B:
> --------------
>
>
> 2013-06-13 02:10:43,257 [.19.48.24:61617] WARN  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker interrupted ...
> 2013-06-13 02:10:43,266 [.19.48.24:61617] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 02:10:43,266 [ker: 1430534144] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://172.19.48.24:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 02:11:08,805 [.19.48.24:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 02:11:08,805 [ker: 1430534144] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:11:09,239 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:11:09,239 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 02:11:09,239 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 02:11:09,239 [ker: 1430534144] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 02:11:09,239 [ker: 1430534144] INFO  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker resumed
> 2013-06-13 02:11:09,328 [Thread-8       ] INFO  DemandForwardingBridge
> - Network connection between vm://avayaiq1cr.cam.wal-mart.com-broker#0 and
> ssl://
> 172.19.48.24:61617?wireFormat.maxInactivityDuration=600000(avayaiqe1.ivr.wal-mart.com-broker)
> has been established.
> 2013-06-13 02:11:09,333 [.19.48.24:61617] DEBUG DemandForwardingBridge
> - Forwarding sub on vm://avayaiq1cr.cam.wal-mart.com-broker#0 from
> avayaiqe1.ivr.wal-mart.com-broker :  ConsumerInfo {commandId = 12,
> responseRequired = true, consumerId =
> ID:avayaiqe1.ivr.wal-mart.com-55507-1368756619514-1:9:5:1, destination =
> topic://com.avaya.syncandnotification.namemgmt.NOTIFICATIONTOPIC,
> prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
> dispatchAsync = false, selector = null, subcriptionName = null, noLocal =
> false, exclusive = false, retroactive = false, priority = 0, brokerPath =
> [ID:avayaiqe1.ivr.wal-mart.com-47420-1369884669888-1:0],
> optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
> null}
> 2013-06-13 02:11:13,070 [iveMQ Scheduler] DEBUG Transport
> - Transport failed: org.apache.activemq.transport.InactivityIOException:
> Channel was inactive for too long.
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
>
> --------------------------------
>
>
> 2013-06-13 02:51:30,871 [.19.48.24:61617] WARN  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker interrupted ...
> 2013-06-13 02:51:30,879 [.19.48.24:61617] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> java.io.EOFException
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 02:51:30,879 [ker: 1430534144] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://172.19.48.24:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 02:51:30,968 [.19.48.24:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 02:51:30,968 [ker: 1430534144] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:51:31,412 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:51:31,412 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 02:51:31,412 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 02:51:31,412 [ker: 1430534144] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 02:51:31,412 [ker: 1430534144] INFO  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker resumed
> 2013-06-13 02:51:31,501 [Thread-10      ] INFO  DemandForwardingBridge
> - Network connection between vm://avayaiq1cr.cam.wal-mart.com-broker#0 and
> ssl://
> 172.19.48.24:61617?wireFormat.maxInactivityDuration=600000(avayaiqe1.ivr.wal-mart.com-broker)
> has been established.
> 2013-06-13 02:51:31,883 [.19.48.24:61617] DEBUG DemandForwardingBridge
> - Forwarding sub on vm://avayaiq1cr.cam.wal-mart.com-broker#0 from
> avayaiqe1.ivr.wal-mart.com-broker :  ConsumerInfo {commandId = 12,
> responseRequired = true, consumerId =
> ID:avayaiqe1.ivr.wal-mart.com-55507-1368756619514-1:9:5:1, destination =
> topic://com.avaya.syncandnotification.namemgmt.NOTIFICATIONTOPIC,
> prefetchSize = 32766, maximumPendingMessageLimit = 0, browser = false,
> dispatchAsync = false, selector = null, subcriptionName = null, noLocal =
> false, exclusive = false, retroactive = false, priority = 0, brokerPath =
> [ID:avayaiqe1.ivr.wal-mart.com-47420-1369884669888-1:0],
> optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate =
> null}
>
> ----------------------
>
>
> 2013-06-13 02:52:31,413 [iveMQ Scheduler] WARN  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker interrupted ...
> 2013-06-13 02:52:31,422 [iveMQ Scheduler] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>         at
>
> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>         at
>
> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:431)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>         at
>
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 02:52:31,422 [ker: 1430534144] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://172.19.48.24:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 02:52:31,511 [.19.48.24:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 02:52:31,511 [ker: 1430534144] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:52:31,947 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:52:31,947 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 02:52:31,947 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 02:52:31,947 [ker: 1430534144] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 02:52:31,947 [ker: 1430534144] INFO  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker resumed
> 2013-06-13 02:52:31,947 [.19.48.24:61617] DEBUG FailoverTransport
> - Transport failed, starting up reconnect task
> java.net.SocketException: Socket closed
>         at java.net.SocketInputStream.socketRead0(Native Method)
>         at java.net.SocketInputStream.read(Unknown Source)
>         at com.sun.net.ssl.internal.ssl.InputRecord.readFully(Unknown
> Source)
>         at com.sun.net.ssl.internal.ssl.InputRecord.read(Unknown Source)
>         at com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(Unknown
> Source)
>         at
> com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(Unknown
> Source)
>         at com.sun.net.ssl.internal.ssl.AppInputStream.read(Unknown Source)
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:48)
>         at
>
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:55)
>         at java.io.DataInputStream.readInt(Unknown Source)
>         at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:274)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 02:52:31,947 [Thread-11      ] DEBUG FailoverTransport
> - Waiting for transport to reconnect.
> 2013-06-13 02:52:31,947 [ker: 1430534144] DEBUG FailoverTransport
> - Attempting connect to:
> ssl://172.19.48.24:61617?wireFormat.maxInactivityDuration=600000
> 2013-06-13 02:52:31,948 [.19.48.24:61617] WARN  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker interrupted ...
> 2013-06-13 02:52:31,948 [.19.48.24:61617] INFO  Service
> - Async error occurred: java.lang.IllegalStateException: Cannot lookup a
> connection that had not been registered:
> ID:avayaiq1cr.cam.wal-mart.com-46291-1369884580806-3:7
> java.lang.IllegalStateException: Cannot lookup a connection that had not
> been registered: ID:avayaiq1cr.cam.wal-mart.com-46291-1369884580806-3:7
>         at
>
> org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:241)
>         at
>
> org.apache.activemq.broker.AbstractConnection.processRemoveConnection(AbstractConnection.java:519)
>         at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:59)
>         at
>
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
>         at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
>         at
>
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
>         at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
>         at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
>         at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>         at
>
> org.apache.activemq.network.DemandForwardingBridgeSupport$2.transportInterupted(DemandForwardingBridgeSupport.java:138)
>         at
>
> org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
>         at
>
> org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:223)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport.access$300(FailoverTransport.java:53)
>         at
>
> org.apache.activemq.transport.failover.FailoverTransport$1.onException(FailoverTransport.java:111)
>         at
>
> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:120)
>         at
>
> org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)
>         at
>
> org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:100)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:156)
>         at java.lang.Thread.run(Unknown Source)
> 2013-06-13 02:52:31,948 [tcher: 98401221] WARN  DemandForwardingBridge
> - Unexpected local command: ConnectionError {commandId = 1599,
> responseRequired = false, connectionId = null, exception =
> java.lang.IllegalStateException: Cannot lookup a connection that had not
> been registered: ID:avayaiq1cr.cam.wal-mart.com-46291-1369884580806-3:7}
> 2013-06-13 02:52:32,040 [.19.48.24:61617] DEBUG TcpTransport
> - TCP consumer thread starting
> 2013-06-13 02:52:32,040 [ker: 1430534144] DEBUG WireFormatNegotiator
> - Sending: WireFormatInfo { version=1,
> properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
> SizePrefixDisabled=false, StackTraceEnabled=true,
> MaxInactivityDuration=600000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:52:32,472 [ker: 1430534144] DEBUG FailoverTransport
> - Connection established
> 2013-06-13 02:52:32,472 [ker: 1430534144] INFO  DemandForwardingBridge
> - Outbound transport to avayaiqe1.ivr.wal-mart.com-broker resumed
> 2013-06-13 02:52:32,472 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - Received WireFormat: WireFormatInfo { version=1,
> properties={StackTraceEnabled=true, TightEncodingEnabled=true,
> TcpNoDelayEnabled=true, SizePrefixDisabled=false,
> MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> 2013-06-13 02:52:32,472 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 before negotiation:
> OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false,
> tightEncodingEnabled=false, sizePrefixDisabled=false}
> 2013-06-13 02:52:32,472 [.19.48.24:61617] DEBUG WireFormatNegotiator
> - tcp://avayaiqe1.ivr.wal-mart.com/172.19.48.24:61617 after negotiation:
> OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true,
> tightEncodingEnabled=true, sizePrefixDisabled=false}
> 2013-06-13 02:52:32,560 [Thread-12      ] INFO  DemandForwardingBridge
> - Network connection between vm://avayaiq1cr.cam.wal-mart.com-broker#0 and
> ssl://
> 172.19.48.24:61617?wireFormat.maxInactivityDuration=600000(avayaiqe1.ivr.wal-mart.com-broker)
> has been established.
> 2013-06-13 02:53:11,614 [eckpoint Worker] DEBUG JournalPersistenceAdapter
> - Checkpoint started.
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/DemandForwardingBridge-Ignoring-sub-ConsumerInf-tp4668211p4668353.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

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