[jboss-svn-commits] JBL Code SVN: r13976 - 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-08-02 22:37:39 -0400 (Thu, 02 Aug 2007)
New Revision: 13976

Modified:
   labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java
Log:
Updated to include Junit assert for test validation.



Modified: labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java	2007-08-03 01:58:10 UTC (rev 13975)
+++ labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java	2007-08-03 02:37:39 UTC (rev 13976)
@@ -1,52 +1,65 @@
-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.dynamicRouter.test.*;
-import org.jboss.soa.esb.samples.quickstart.dynamicRouter.*;
-
-/**
- * Sample client for the jboss container.
- *
- * @author <a href="mailto:"></a>
- * @version $Id: $
- */
-
-public class DynamicRouterTest
-        extends JBossTestCase
-{
-	private static final String JMS_MESSAGE = "FOOBAResbmessage";
-	public DynamicRouterTest(String name)
-	{
-		super(name);
-	}
-
-	public void testMessage() throws Exception
-	{
-		sendMessage();
-		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 static Test suite() throws Exception
-   {
-      return getDeploySetup(DynamicRouterTest.class, "Quickstart_dynamic_router.esb");
-   }
-}
+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 java.util.Hashtable;
+
+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.dynamicRouter.test.*;
+import org.jboss.soa.esb.samples.quickstart.dynamicRouter.*;
+
+import org.jboss.soa.esb.quickstart.test.Helpers;
+
+/**
+ * Sample client for the jboss container.
+ *
+ * @author <a href="mailto:"></a>
+ * @version $Id: $
+ */
+
+public class DynamicRouterTest extends JBossTestCase
+{
+	private static final String JMS_MESSAGE = "DynamicRouterTest message";
+	private static final String LOG_FILE = "/opt/DynamicRouterTest.log";
+	
+	public DynamicRouterTest(String name)
+	{
+		super(name);
+	}
+
+	public void testMessage() throws Exception
+	{
+		sendMessage();
+		Thread.sleep(10000); // wait for message to post.
+		Hashtable theTable = Helpers.getMessageString(LOG_FILE);
+		String theMessage = (String) theTable.get("Message1");
+		assertEquals("The strings should match", theMessage, JMS_MESSAGE);
+	}
+
+	public void sendMessage() throws Exception
+	{
+		ReceiveJMSMessage rm =  new ReceiveJMSMessage();
+		rm.setupConnection();
+		rm.sendAMessage("queue/qsdynamicrouter_1_Request:OK");
+		rm.sendAMessage("queue/qsdynamicrouter_2_Request:OK");
+		rm.sendAMessage("queue/qsdynamicrouter_3_Request:OK");
+		
+	    	SendJMSMessage sm = new SendJMSMessage();
+    		sm.setupConnection();
+		sm.sendAMessage(JMS_MESSAGE + Helpers.START_TAG + LOG_FILE + Helpers.END_TAG);
+	    	sm.stop();
+	}
+
+   public static Test suite() throws Exception
+   {
+      return getDeploySetup(DynamicRouterTest.class, "Quickstart_dynamic_router.esb");
+   }
+}