activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vijay <vijayender.band...@gmail.com>
Subject Junit Testing Master/Slave Program Hangs forever..
Date Fri, 24 Jun 2011 19:55:29 GMT
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