Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (herse.apache.org: domain of sukoneru@cisco.com designates
 171.71.176.71 as permitted sender)
Content-class: urn:content-classes:message
MIME-Version: 1.0
Content-Type: text/plain;
	charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
Subject: FW: active mq broker start up issue.
Date: Tue, 24 Jul 2007 11:19:07 -0700
Message-ID: 
 <5BD9FA70F5EDAC43AB816A5FDE30F6AC04C30E0F@xmb-sjc-21a.amer.cisco.com>
Thread-Topic: active mq broker start up issue.
Thread-Index: AcfNY6XBORBbC4+3Te6Ahs54X/yItwAu19tg
From: "Suchitha Koneru \(sukoneru\)" <sukoneru@cisco.com>
To: <users@activemq.apache.org>

=20
Any suggestions in this regard ? Please let me know,
Thank you,
Suchitha.
-----Original Message-----
From: Suchitha Koneru (sukoneru)=20
Sent: Monday, July 23, 2007 12:57 PM
To: users@activemq.apache.org
Subject: active mq broker start up issue.

Hello Active MQ users ,=20
=20
We use Tomcat server 5.5.20 with two web applications , namely Webapp A
and Web App. B.
The inter web app communication is via the active mq broker.  The active
mq version is 4..0.2 .=20
As of now, the web app A is always started before B. Hence the broker is
specified as a Servlet Context Listener in web.xml of the web app A.
The problem we have  is to start the broker irrespective of the order of
initialization of  web apps .
  We would be adding a new web app called Webapp C . In this scenario, I
will not have a control on the order in which the web apps are
initialized by Tomcat. The code to start the broker , takes into
account, that if the broker port is already occupied, it will  attempt
to start the broker at a randomly generated  port for 5 times.
=20
 Tomcat does not give us the flexibility of starting the web apps in
particular order.  The web.xml of Webapp A is as follows=20
=20
<!-- starting active mq broker -->

<listener>

<listener-class>com.messaging.ActiveMQBrokerStartListener</listener-clas
s>

</listener>

<!-- starting the rest of services in web app   A -->

<listener>

<listener-class>

com.context.ApplicationInitListener

</listener-class>

</listener>

=20

// code for ActiveMQBrokerStartListener

BrokerService broker =3D new BrokerService();

int counter =3D 0;

Properties activeMQProperties =3D new Properties() ;

=20

int portNum ;

public void contextInitialized(ServletContextEvent arg0) {

System.out.println("Starting ActiveMQ Broker Service...");

//for the broker URI , do not have leading or trailing spaces

File dir =3D new File("../../activemq");

Logger logger =3D Logger.getLogger(ActiveMQBrokerStartListener.class);

dir.mkdir();

InetAddress ipAdress ;

broker.setDataDirectory(dir);

try{

ipAdress =3D InetAddress.getLocalHost();

}catch(UnknownHostException e){

logger.error("error in obtaining Local Host address "+e.getMessage());

return ;

}

// getting the port number from the active mq properties file

try{

activeMQProperties.load(new
FileInputStream(MessagingConstants.ACTIVEMQ_PORT_FILE_PATH ));

portNum =3D
Integer.parseInt(activeMQProperties.getProperty(MessagingConstants.Activ
eMQPort,"-1"));

if(portNum =3D=3D -1){

logger.error("active mq port not configured via the proeprties file
using the default port value as
"+MessagingConstants.DEFAULT_PORT_VALUE);

portNum =3D MessagingConstants.DEFAULT_PORT_VALUE ;

}

}catch(Exception e){

logger.error("exception while getting port properties "+e.getMessage());

}

while(counter < 5){ // 5 attempts to start the broker=20

try{=20

// broker url is
tcp://171.69.155.137:61716?trace=3Dtrue&wireFormat.maxInactivityDuration=3D=
-
1

broker.addConnector(MessagingConstants.CONNECTOR+
ipAdress.getHostAddress()+":"+portNum+MessagingConstants.ACTIVEMQ_URL_SU
FFIX);

broker.start();

logger.info("Active MQ Broker Started at local host port "+ portNum);

break;

}catch(Exception e){

// System.out.println(e.getMessage());

if(e instanceof java.net.BindException){ //broker port is already
occupied by another process, try to start the broker at different=20

// port number

portNum =3D getRandomPortNumber() ;

logger.info("trying to start the broker at port "+portNum);

counter ++;

}else{

logger.error("exception while starting broker : ",e);

e.printStackTrace();

}

}

}

Please let me know, if there is a way to ensure that the broker is
started first , irrespective of the order of initilization of web apps.
I'll also do a  google search on this issue.

thanks,

Suchitha.