[jboss-remoting-commits] JBoss Remoting SVN: r4070 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2008-04-25 00:59:31 -0400 (Fri, 25 Apr 2008)
New Revision: 4070

Modified:
   remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ServerLauncher.java
Log:
JBREM-969: Can now shut down Connectors at end of run.

Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ServerLauncher.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ServerLauncher.java	2008-04-25 04:58:36 UTC (rev 4069)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/soak/ServerLauncher.java	2008-04-25 04:59:31 UTC (rev 4070)
@@ -57,6 +57,7 @@
 {
    private static Logger log = Logger.getLogger(ServerLauncher.class);
    private static Map locators = new HashMap();
+   private static Connector[] connectors = new Connector[4];
    
    public static Map getLocators()
    {
@@ -76,19 +77,31 @@
          
          String host = InetAddress.getLocalHost().getHostAddress();
          
-         Connector connector = setupServer(host, 6666, "bisocket");
-         locators.put("bisocket", connector.getLocator().getLocatorURI());
+         connectors[0] = setupServer(host, 6666, "bisocket");
+         locators.put("bisocket", connectors[0].getLocator().getLocatorURI());
          
-         connector = setupServer(host, 6667, "http");
-         locators.put("http", connector.getLocator().getLocatorURI());
+         connectors[1] = setupServer(host, 6667, "http");
+         locators.put("http", connectors[1].getLocator().getLocatorURI());
          
-         connector = setupServer(host, 6668, "rmi");
-         locators.put("rmi", connector.getLocator().getLocatorURI());
+         connectors[2] = setupServer(host, 6668, "rmi");
+         locators.put("rmi", connectors[2].getLocator().getLocatorURI());
          
-         connector = setupServer(host, 6669, "socket");
-         locators.put("socket", connector.getLocator().getLocatorURI());
+         connectors[3] = setupServer(host, 6669, "socket");
+         locators.put("socket", connectors[3].getLocator().getLocatorURI());
          
          log.info("SERVERS CREATED: " + locators);
+         
+         System.in.read();
+         System.in.read();
+         System.in.read();
+         
+         log.info("SHUTTING DOWN SERVERS");
+         for (int i = 0; i < connectors.length; i++)
+         {
+            connectors[i].stop();
+         }
+         log.info("SERVERS SHUT DOWN");
+         
       }
       catch (Exception e)
       {