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.
