activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eric-AWL <eric.vinc...@atosorigin.com>
Subject Re: 5.3.2 : DemandForwardingBridge and Failover interaction ?
Date Tue, 13 Jul 2010 08:28:52 GMT

Problem seems to be localized here

When it works Ok :

 09:11:02,704 [ActiveMQ Task  ] DEBUG AbstractRegion                 -
localhost removing consumer:
ID:td0sib01s.priv.atos.fr-53632-1279005032084-2:3:2:1 for destination:
queue://FailoverWithOutstandingCommit

2010-07-13 09:11:02,705 [127.0.0.1:61616] WARN  FailoverTransport             
- Transport failed to tcp://localhost:61616 , attempting to automatically
reconnect due to: java.io.EOFException
2010-07-13 09:11:02,705 [ActiveMQ Task  ] DEBUG Queue                         
- remove sub: QueueSubscription:
consumer=ID:td0sib01s.priv.atos.fr-53632-1279005032084-2:3:2:1,
destinations=1, dispatched=1, delivered=0, pending=0, lastDeliveredSeqId: 0,
dequeues: 0, dispatched: 1, inflight: 1
2010-07-13 09:11:02,705 [127.0.0.1:61616] DEBUG FailoverTransport             
- Transport failed with the following exception:
java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:375)
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:211)
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:186)
	at java.lang.Thread.run(Thread.java:619)
2010-07-13 09:11:02,705 [127.0.0.1:61616] DEBUG ActiveMQConnection            
- transport interrupted, dispatchers: 1


2010-07-13 09:11:02,706 [iveMQ Scheduler] DEBUG ActiveMQMessageConsumer       
- ID:td0sib01s.priv.atos.fr-53632-1279005032084-2:3:2:1 clearing dispatched
list (0) on transport interrupt


2010-07-13 09:11:02,706 [ActiveMQ Task  ] DEBUG FailoverTransport             
- urlList connectionList:[tcp://localhost:61616]
2010-07-13 09:11:02,706 [ActiveMQ Task  ] DEBUG Queue                         
- FailoverWithOutstandingCommit toPageIn: 0, Inflight: 0,
pagedInMessages.size 1, enqueueSize: 1
2010-07-13 09:11:02,706 [ActiveMQ Task  ] DEBUG FailoverTransport             
- Attempting connect to: tcp://localhost:61616

2010-07-13 09:11:02,707 [ActiveMQ Task  ] DEBUG AbstractRegion                
- localhost removing consumer:
ID:td0sib01s.priv.atos.fr-53632-1279005032084-2:3:-1:1 for destination:
topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic
.....


When it blocks

2010-07-13 09:00:35,721 [ActiveMQ Task  ] DEBUG AbstractRegion                
- localhost removing consumer:
ID:td0sib02s.priv.atos.fr-59537-1279004433513-2:0:-1:1 for destination:
topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic
...
2010-07-13 09:00:35,722 [ActiveMQ Task  ] DEBUG AbstractRegion                
- localhost removing consumer:
ID:td0sib02s.priv.atos.fr-59537-1279004433513-2:0:2:1 for destination:
queue://FailoverWithOutstandingCommit


2010-07-13 09:00:35,722 [ActiveMQ Task  ] DEBUG Queue                         
- remove sub: QueueSubscription:
consumer=ID:td0sib02s.priv.atos.fr-59537-1279004433513-2:0:2:1,
destinations=1, dispatched=11, delivered=1, pending=0, lastDeliveredSeqId:
0, dequeues: 0, dispatched: 11, inflight: 11
2010-07-13 09:00:35,723 [127.0.0.1:61616] WARN  FailoverTransport             
- Transport failed to tcp://localhost:61616 , attempting to automatically
reconnect due to: java.io.EOFException
2010-07-13 09:00:35,724 [127.0.0.1:61616] DEBUG FailoverTransport             
- Transport failed with the following exception:

2010-07-13 09:00:35,724 [127.0.0.1:61616] DEBUG FailoverTransport             
- Transport failed with the following exception:
java.io.EOFException
	at java.io.DataInputStream.readInt(DataInputStream.java:375)
	at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
	at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:211)
	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:186)
	at java.lang.Thread.run(Thread.java:619)
2010-07-13 09:00:35,724 [BrokerService  ] DEBUG Queue                         
- FailoverWithOutstandingCommit toPageIn: 0, Inflight: 0,
pagedInMessages.size 20, enqueueSize: 20
2010-07-13 09:00:35,725 [127.0.0.1:61616] DEBUG ActiveMQConnection            
- transport interrupted, dispatchers: 1
...
2010-07-13 09:01:05,907 [127.0.0.1:61616] WARN  ActiveMQConnection            
- dispatch paused, waiting for outstanding dispatch interruption processing
(1) to complete..
....


It's the way messageConsumers (and corresponding sessions) are cleared that
impacts the "transportInterruptionProcessingComplete"  countdown latch value

Eric-AWL


-- 
View this message in context: http://old.nabble.com/5.3.2-%3A-DemandForwardingBridge-and-Failover-interaction---tp29147602p29147878.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message