[hornetq-commits] JBoss hornetq SVN: r9635 - branches/Branch_2_1/examples/common/src/org/hornetq/common/example.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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"))
       {