activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mmg <manjusha.g...@gmail.com>
Subject Re: DemandForwardingBridge - Ignoring sub ConsumerInf
Date Wed, 19 Jun 2013 11:50:38 GMT
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
View raw message