activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stan Lewis <sle...@fusesource.com>
Subject Re: Junit Testing Master/Slave Program Hangs forever..
Date Sun, 26 Jun 2011 23:53:01 GMT
move the calls to "waitUntilStarted" so they're *after* the calls to
start the master and slave, should do the trick...

On Fri, Jun 24, 2011 at 3:55 PM, Vijay <vijayender.bandaru@gmail.com> wrote:
> For Junit testing failover , I want to start Master/slave instances with
> following piece of code. After Master starts, it hangs forever.  If I make
> waitForSlave=true, seems to be working. But I want to test it with wait for
> slave on..Pls. help.
>
> LOG
> -----
> INFO  [main] - Refreshing
> org.apache.xbean.spring.context.ResourceXmlApplicationContext@bd0108:
> startup date [Fri Jun 24 15:45:49 EDT 2011]; root of context hierarchy
> INFO  [main] - Loading XML bean definitions from class path resource
> [master.xml]
> INFO  [main] - Pre-instantiating singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@1a99561:
> defining beans
> [org.springframework.beans.factory.config.PropertyPlaceholderConfigurer#0,org.apache.activemq.xbean.XBeanBrokerService#0];
> root of factory hierarchy
> INFO  [main] - PListStore:activemq-data\master\tmp_storage started
> INFO  [main] - Using Persistence Adapter:
> KahaDBPersistenceAdapter[C:\master_slave_prototype\activemq-data\master\KahaDB]
> INFO  [main] - Persistence store purged.
> INFO  [main] - ActiveMQ 5.5.0 JMS Message Broker (master) is starting
> INFO  [main] - For help or more information please see:
> http://activemq.apache.org/
> INFO  [main] - Listening for connections at: tcp://HDC00020891:61616
> INFO  [main] - Connector tcp://0.0.0.0:61616 Started
>
> <<After this I could not see logs for Master/Slave started >>
>
> Code
> ------
>
> public void testMasterSlave(){
>
>                 BrokerFactoryBean masterBrokerFactory = new BrokerFactoryBean(new
> ClassPathResource("master.xml"));
>         masterBrokerFactory.afterPropertiesSet();
>         final BrokerService masterBroker = masterBrokerFactory.getBroker();
>
>         BrokerFactoryBean slaveBrokerFactory = new BrokerFactoryBean(new
> ClassPathResource("slave.xml"));
>             slaveBrokerFactory.afterPropertiesSet();
>             final BrokerService slaveBroker = slaveBrokerFactory.getBroker();
>
>             masterBroker.start();
>             masterBroker.waitUntilStarted();
>             LOG.info("Master started ...");
>
>             slaveBroker.start();
>             slaveBroker.waitUntilStarted();
>             LOG.info("Slave started ...");
>
>              //Stop Master
>             masterBroker.stop();
>             masterBroker.waitUntilStopped();
>
>             assertTrue("Slave became master now ?", !slaveBroker.isSlave());
>
>
> }
> Master.xml
> ------------
>
>  <broker brokerName="master" useJmx="false" persistent="true"
> waitForSlave="true" deleteAllMessagesOnStartup="true"
> xmlns="http://activemq.apache.org/schema/core">
>
>   <transportConnectors>
>     <transportConnector uri="tcp://localhost:61616"/>
>   </transportConnectors>
>
>  </broker>
>
> Slave.xml
> -----------
>
>  <broker brokerName="slave" deleteAllMessagesOnStartup="true" useJmx="false"
> masterConnectorURI="tcp://localhost:61616?wireFormat.maxInactivityDurationInitalDelay=90000"
> persistent="true" xmlns="http://activemq.apache.org/schema/core">
>   <transportConnectors>
>     <transportConnector uri="tcp://localhost:61617"/>
>   </transportConnectors>
>
>  </broker>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Junit-Testing-Master-Slave-Program-Hangs-forever-tp3623477p3623477.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
View raw message