[jboss-svn-commits] JBL Code SVN: r14182 - 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-13 13:18:30 -0400 (Mon, 13 Aug 2007)
New Revision: 14182

Modified:
   labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java
Log:
Updated to no longer include sleep()'s to wait for message to be queued - now uses Helpers.checkForFile()




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-13 17:13:37 UTC (rev 14181)
+++ labs/jbossesb/trunk/product/samples/quickstarts/tests/src/org/jboss/soa/esb/quickstart/test/DynamicRouterTest.java	2007-08-13 17:18:30 UTC (rev 14182)
@@ -19,8 +19,8 @@
 public class DynamicRouterTest extends JBossTestCase
 {
 	private static final String JMS_MESSAGE = "DynamicRouterTest message";
-    private static final String FILE_NAME = "DynamicRouterTest.log";
-    private static final String LOG_FILE = Helpers.getTempDir(FILE_NAME) + FILE_NAME;
+	private static final String FILE_NAME = "DynamicRouterTest.log";
+	private static final String LOG_FILE = Helpers.getTempDir(FILE_NAME) + FILE_NAME;
 	
 	public DynamicRouterTest(String name)
 	{
@@ -30,7 +30,11 @@
 	public void testMessage() throws Exception
 	{
 		sendMessage();
-		Thread.sleep(10000); // wait for message to post.
+               /* Verify that the message file is created */
+                boolean fileExists = Helpers.checkForFile(LOG_FILE);
+                if (!fileExists) {
+                        fail ("Event file " + LOG_FILE + " not created - test marked as failing");
+                }   
 		Hashtable theTable = Helpers.getMessageString(LOG_FILE);
 
 		String theMessage1 = (String) theTable.get("Message1");
@@ -52,7 +56,7 @@
 		rm.sendAMessage("queue/qsdynamicrouter_1_Request:OK");
 		rm.sendAMessage("queue/qsdynamicrouter_2_Request:OK");
 		rm.sendAMessage("queue/qsdynamicrouter_3_Request:OK");
-        rm.stop();
+	        rm.stop();
 		
 	    	SendJMSMessage sm = new SendJMSMessage();
     		sm.setupConnection();