Below is the output from a unit test I wrote to demonstrate the problem.
here is the summary from what is highlighted:
14:34:28 - send "Hello, World!"
14:34:29 - receive "Hello, World!"
14:34:34 - remind myself to shutdown master broker, i.e. localhost:61626
14:34:40 - amq detects transport failure on master
14:34:51 - amq reconnects to slave, i.e. localhost:61616. Also 2 onCommand()
invocations
14:35:04 - send "Hello, World!"
14:35:34 - shutdown because I gave up on waiting to receive.
What is going on after 14:34:51? no continuous onCommand() invocations nor
ability to receive the second message!
thanks,
vadim
14:34:27 INFO org.springframework.test.context.TestContextManager
@TestExecutionListeners is not present for class [class
vadim.sample.jms.activemq.JobSenderTest]: using defaults.
14:34:27 INFO org.springframework.beans.factory.xml.XmlBeanDefinitionReader
Loading XML bean definitions from class path resource
[applicationContext.xml]
14:34:27 INFO org.springframework.context.support.GenericApplicationContext
Refreshing
[EMAIL PROTECTED]:
display name
[EMAIL PROTECTED];
startup date [Wed Sep 10 14:34:27 PDT 2008]; root of context hierarchy
14:34:27 INFO org.springframework.context.support.GenericApplicationContext
Bean factory for application context
[EMAIL PROTECTED]:
[EMAIL PROTECTED]
14:34:27 INFO
org.springframework.beans.factory.support.DefaultListableBeanFactory
Pre-instantiating singletons in
[EMAIL PROTECTED]:
defining beans
[jmsExceptionListener,jmsPrefetchPolicy,jmsRedeliveryPolicy,activeMQConnectionFactory,activeMQPooledConnectionFactory,jmsTemplate,destination,listenerContainer,messageListener,jobReceiver,jobSender,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor];
root of factory hierarchy
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportResumed is called
14:34:28 INFO org.apache.activemq.transport.failover.FailoverTransport
Successfully connected to tcp://localhost:61626
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:28 INFO vadim.sample.jms.activemq.JobSender Sending message: Hello,
World!
14:34:28 INFO org.springframework.jms.connection.SingleConnectionFactory
Established shared JMS Connection: PooledConnection {
[EMAIL PROTECTED] }
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportResumed is called
14:34:28 INFO org.apache.activemq.transport.failover.FailoverTransport
Successfully connected to tcp://localhost:61626
14:34:28 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:29 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:29 INFO vadim.sample.jms.activemq.JobReceiver Received message:
Hello, World!
14:34:30 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:31 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:32 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:33 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:34 INFO vadim.sample.jms.activemq.JobSenderTest Shutdown master
broker!!!
14:34:34 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:35 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:36 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:37 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:38 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:39 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:40 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:40 WARN org.apache.activemq.transport.failover.FailoverTransport
Transport failed to tcp://localhost:61626 , attempting to automatically
reconnect due to: java.io.EOFException
14:34:40 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportInterupted is called
14:34:41 WARN org.apache.activemq.transport.failover.FailoverTransport
Transport failed to tcp://localhost:61626 , attempting to automatically
reconnect due to: java.io.EOFException
14:34:41 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportInterupted is called
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportResumed is called
14:34:51 INFO org.apache.activemq.transport.failover.FailoverTransport
Successfully reconnected to tcp://localhost:61616
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener
transportResumed is called
14:34:51 INFO org.apache.activemq.transport.failover.FailoverTransport
Successfully reconnected to tcp://localhost:61616
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:34:51 INFO vadim.sample.jms.activemq.ActiveMQTransportListener onCommand
is called
14:35:04 INFO vadim.sample.jms.activemq.JobSender Sending message: Hello,
World!
14:35:34 INFO org.springframework.context.support.GenericApplicationContext
Closing
[EMAIL PROTECTED]:
display name
[EMAIL PROTECTED];
startup date [Wed Sep 10 14:34:27 PDT 2008]; root of context hierarchy
14:35:34 INFO
org.springframework.beans.factory.support.DefaultListableBeanFactory
Destroying singletons in
[EMAIL PROTECTED]:
defining beans
[jmsExceptionListener,jmsPrefetchPolicy,jmsRedeliveryPolicy,activeMQConnectionFactory,activeMQPooledConnectionFactory,jmsTemplate,destination,listenerContainer,messageListener,jobReceiver,jobSender,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor];
root of factory hierarchy
--
View this message in context:
http://www.nabble.com/sends-receives-block-during-failover-tp19415060p19423862.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
