[jboss-svn-commits] JBL Code SVN: r10152 - in labs/jbossesb/workspace/jboss-remoting/product/core: rosetta/tests/src/org/jboss/internal/soa/esb/couriers and 1 other directory.

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

Author: tfennelly
Date: 2007-03-13 08:03:51 -0400 (Tue, 13 Mar 2007)
New Revision: 10152

Modified:
   labs/jbossesb/workspace/jboss-remoting/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/gateway/JBossRemotingGatewayListenerUnitTest.java
   labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourier.java
   labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourierFactory.java
Log:
changes to support some profiling

Modified: labs/jbossesb/workspace/jboss-remoting/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/gateway/JBossRemotingGatewayListenerUnitTest.java
===================================================================
--- labs/jbossesb/workspace/jboss-remoting/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/gateway/JBossRemotingGatewayListenerUnitTest.java	2007-03-13 07:52:43 UTC (rev 10151)
+++ labs/jbossesb/workspace/jboss-remoting/product/core/listeners/tests/src/org/jboss/soa/esb/listeners/gateway/JBossRemotingGatewayListenerUnitTest.java	2007-03-13 12:03:51 UTC (rev 10152)
@@ -58,13 +58,7 @@
     protected void tearDown() throws Exception {
         MockRegistry.uninstall();
         MockCourierFactory.uninstall();
-        if(listener != null && listener.isStarted()) {
-            try {
-                listener.doStop();
-            } finally {
-                listener.doDestroy();
-            }
-        }
+        stopServer();
     }
 
     public void test_config() throws SAXException {
@@ -138,19 +132,32 @@
     }
 
     public void test_delivery(String protocol) throws Throwable {
+        startServer(protocol);
+        sendMessageToServer(protocol, protocol + "_payload");
+        stopServer();
+    }
+
+    public void x_test_profile() throws Throwable {
+        startServer("http");
+        for(int i = 0; i < 10000; i++) {
+            sendMessageToServer("http", "xxx_payload");
+            MockCourierFactory.resetCouriers();
+            Thread.sleep(50);
+        }
+        stopServer();
+    }
+
+    private void startServer(String protocol) throws SAXException, ConfigurationException, ManagedLifecycleException {
         ConfigTree config = getConfig("cat", "servicex", protocol, "8888");
 
         listener = new JBossRemotingGatewayListener(config);
 
         listener.doInitialise();
         listener.doStart();
-
-        // Add test...
-        sendMessageToServer(protocol, "8888", protocol + "_payload");
     }
 
-    private void sendMessageToServer(String protocol, String port, Object messagePayload) throws Throwable {
-        String locatorURI = protocol + "://" + InetAddress.getLocalHost().getHostName() + ":" + port;
+    private void sendMessageToServer(String protocol, Object messagePayload) throws Throwable {
+        String locatorURI = protocol + "://" + InetAddress.getLocalHost().getHostName() + ":8888";
         InvokerLocator locator = new InvokerLocator(locatorURI);
         System.out.println("Calling remoting server with locator uri of: " + locatorURI);
 
@@ -176,6 +183,16 @@
         }
     }
 
+    private void stopServer() throws ManagedLifecycleException {
+        if(listener != null && listener.isStarted()) {
+            try {
+                listener.doStop();
+            } finally {
+                listener.doDestroy();
+            }
+        }
+    }
+
     private ConfigTree getConfig(String category, String service, String protocol, String port) throws SAXException {
         ConfigTree config = ConfigTree.fromXml("<listener/>");
 

Modified: labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourier.java
===================================================================
--- labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourier.java	2007-03-13 07:52:43 UTC (rev 10151)
+++ labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourier.java	2007-03-13 12:03:51 UTC (rev 10152)
@@ -67,4 +67,9 @@
 
     public void cleanup() {
     }
+
+    public void reset() {
+        message = null;
+        deliveryAttempted = false;
+    }
 }

Modified: labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourierFactory.java
===================================================================
--- labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourierFactory.java	2007-03-13 07:52:43 UTC (rev 10151)
+++ labs/jbossesb/workspace/jboss-remoting/product/core/rosetta/tests/src/org/jboss/internal/soa/esb/couriers/MockCourierFactory.java	2007-03-13 12:03:51 UTC (rev 10152)
@@ -26,6 +26,8 @@
 import org.jboss.soa.esb.addressing.MalformedEPRException;
 
 import java.util.Hashtable;
+import java.util.Iterator;
+import java.util.Map;
 
 /**
  * Mock CourierFactory.
@@ -63,4 +65,10 @@
         courierException = null;
         malformedEPRException = null;
     }
+
+    public static void resetCouriers() {
+        for (Map.Entry<EPR, Courier> entry : couriers.entrySet()) {
+            ((MockCourier)entry.getValue()).reset();
+        }
+    }
 }