[jboss-svn-commits] JBL Code SVN: r13792 - labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test.

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

Author: ldimaggi at redhat.com
Date: 2007-07-25 22:02:41 -0400 (Wed, 25 Jul 2007)
New Revision: 13792

Added:
   labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/WiretapTest.java
Log:
Initial checkin - test for wiretap quickstart



Added: labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/WiretapTest.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/WiretapTest.java	                        (rev 0)
+++ labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/WiretapTest.java	2007-07-26 02:02:41 UTC (rev 13792)
@@ -0,0 +1,89 @@
+package org.jboss.soa.esb.quickstart.test;
+
+import java.io.OutputStream;
+import java.io.PrintStream;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.Date;
+
+import javax.management.ObjectName;
+import junit.framework.Test;
+
+import org.jboss.soa.esb.StatsMBean;
+import org.jboss.test.JBossTestCase;
+
+import org.jboss.soa.esb.samples.quickstart.wiretap.test.*;
+import org.jboss.soa.esb.samples.quickstart.wiretap.*;
+
+/**
+ * Sample client for the jboss container.
+ *
+ * @author <a href="mailto:"></a>
+ * @version $Id: $
+ */
+
+public class WiretapTest
+        extends JBossTestCase
+{
+	private static final String JMS_MESSAGE = "FOOBAResbmessage";
+
+        private static final String JMS_CBR_MESSAGE = "<Order sampleData=\"CBR wiretap test\" testDate=\"20070518\" routeToFollow=\"both\"><Customer userName=\"user1\" firstName=\"Harry\" lastName=\"Fletcher\" state=\"SD\"/></Order>";
+
+
+	public WiretapTest(String name)
+	{
+		super(name);
+	}
+
+	public void testMessage() throws Exception
+	{
+		sendMessage();
+		Thread.sleep(10000); // wait for message to post.
+                sendWiretapMessage();
+                Thread.sleep(10000); // wait for message to post.
+                sendStaticRouterJMSMessage();
+                Thread.sleep(10000); // wait for message to post.
+                sendCBRJMSMessage();
+                Thread.sleep(10000); // wait for message to post.
+	}
+
+	public void sendMessage() throws Exception
+	{
+    	SendJMSMessage sm = new SendJMSMessage();
+    	sm.setupConnection();
+    	sm.sendAMessage(JMS_MESSAGE);
+        sm.stop();
+        }
+
+        public void sendCBRJMSMessage() throws Exception
+        {
+        SendCBRJMSMessage sm = new SendCBRJMSMessage();
+        sm.setupConnection();
+        sm.sendAMessage(JMS_CBR_MESSAGE);
+        sm.stop();
+        }
+
+        public void sendWiretapMessage() throws Exception
+        {
+        SendWiretapJMSMessage sm = new SendWiretapJMSMessage();
+        sm.setupAConnection();
+        sm.sendMessage(JMS_MESSAGE);
+        sm.stop();
+        }
+
+        public void sendStaticRouterJMSMessage() throws Exception
+        {
+        SendStaticRouterJMSMessage sm = new SendStaticRouterJMSMessage();
+        sm.setupConnection();
+        sm.sendAMessage(JMS_MESSAGE);
+        sm.stop();
+        }
+
+
+
+
+   public static Test suite() throws Exception
+   {
+      return getDeploySetup(WiretapTest.class, "Quickstart_wiretap.esb");
+   }
+}