Junit Testing Master/Slave Program Hangs forever..

[Vijay]

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.