activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vadimos <vadim_k...@yahoo.com>
Subject Re: sends/receives block during failover
Date Wed, 10 Sep 2008 21:51:11 GMT

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
org.springframework.context.support.GenericApplicationContext@117a8bd:
display name
[org.springframework.context.support.GenericApplicationContext@117a8bd];
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
[org.springframework.context.support.GenericApplicationContext@117a8bd]:
org.springframework.beans.factory.support.DefaultListableBeanFactory@a9c09e
14:34:27 INFO 
org.springframework.beans.factory.support.DefaultListableBeanFactory
Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@a9c09e:
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 {
org.apache.activemq.pool.ConnectionPool@b60b93 }
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
org.springframework.context.support.GenericApplicationContext@117a8bd:
display name
[org.springframework.context.support.GenericApplicationContext@117a8bd];
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
org.springframework.beans.factory.support.DefaultListableBeanFactory@a9c09e:
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.


Mime
View raw message