[hornetq-commits] JBoss hornetq SVN: r9635 - branches/Branch_2_1/examples/common/src/org/hornetq/common/example.
Author: clebert.suconic(a)jboss.com
Date: 2010-09-02 22:07:52 -0400 (Thu, 02 Sep 2010)
New Revision: 9635
Modified:
branches/Branch_2_1/examples/common/src/org/hornetq/common/example/HornetQExample.java
Log:
tweaks
Modified:
branches/Branch_2_1/examples/common/src/org/hornetq/common/example/HornetQExample.java
===================================================================
---
branches/Branch_2_1/examples/common/src/org/hornetq/common/example/HornetQExample.java 2010-09-03
02:05:02 UTC (rev 9634)
+++
branches/Branch_2_1/examples/common/src/org/hornetq/common/example/HornetQExample.java 2010-09-03
02:07:52 UTC (rev 9635)
@@ -17,8 +17,6 @@
import java.util.Properties;
import java.util.logging.Logger;
-import javax.jms.Connection;
-import javax.jms.JMSException;
import javax.naming.InitialContext;
/**
@@ -32,26 +30,26 @@
private Process[] servers;
- private Connection conn;
+ protected boolean failure = false;
- private boolean failure = false;
+ protected String serverClasspath;
- private String serverClasspath;
+ protected String serverProps;
- private String serverProps;
-
public abstract boolean runExample() throws Exception;
private boolean logServerOutput;
- private String[] configs;
+ protected String[] configs;
+
+ protected boolean runServer;
protected void run(final String[] configs)
{
String runServerProp = System.getProperty("hornetq.example.runServer");
String logServerOutputProp =
System.getProperty("hornetq.example.logserveroutput");
serverClasspath =
System.getProperty("hornetq.example.server.classpath");
- boolean runServer = runServerProp == null ? true : Boolean.valueOf(runServerProp);
+ runServer = runServerProp == null ? true : Boolean.valueOf(runServerProp);
logServerOutput = logServerOutputProp == null ? false :
Boolean.valueOf(logServerOutputProp);
serverProps = System.getProperty("hornetq.example.server.args");
if (System.getProperty("hornetq.example.server.override.args") != null)
@@ -83,17 +81,6 @@
}
finally
{
- if (conn != null)
- {
- try
- {
- conn.close();
- }
- catch (JMSException e)
- {
- // ignore
- }
- }
if (runServer)
{
try
@@ -165,7 +152,7 @@
"hornetq-beans.xml");
}
- private void startServers() throws Exception
+ protected void startServers() throws Exception
{
servers = new Process[configs.length];
for (int i = 0; i < configs.length; i++)
@@ -174,7 +161,7 @@
}
}
- private void stopServers() throws Exception
+ protected void stopServers() throws Exception
{
for (Process server : servers)
{
@@ -185,7 +172,7 @@
}
}
- private void stopServer(final Process server) throws Exception
+ protected void stopServer(final Process server) throws Exception
{
if (!System.getProperty("os.name").contains("Windows")
&& !System.getProperty("os.name").contains("Mac OS X"))
{