[jboss-svn-commits] JBL Code SVN: r11605 - labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions.

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

Author: kurt.stam at jboss.com
Date: 2007-05-02 21:03:41 -0400 (Wed, 02 May 2007)
New Revision: 11605

Modified:
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/ContentBasedRouterTest.java
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/MessagePersisterTest.java
Log:
JBESB-418 Got a message from the preceding test, which was messing things up.

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/ContentBasedRouterTest.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/ContentBasedRouterTest.java	2007-05-03 00:47:22 UTC (rev 11604)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/ContentBasedRouterTest.java	2007-05-03 01:03:41 UTC (rev 11605)
@@ -251,6 +251,7 @@
 	@AfterClass
 	public static void runAfterAllTests() throws Exception
 	{
+        Thread.sleep(2000);
 		// Increase Sleep for debugging
 		_boot.requestEnd();
 		// Give the esb time to finish

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/MessagePersisterTest.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/MessagePersisterTest.java	2007-05-03 00:47:22 UTC (rev 11604)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/MessagePersisterTest.java	2007-05-03 01:03:41 UTC (rev 11605)
@@ -32,6 +32,7 @@
 import java.sql.DriverManager;
 import java.sql.Statement;
 import java.util.Date;
+import java.util.Iterator;
 import java.util.Map;
 import java.util.Properties;
 
@@ -101,6 +102,13 @@
             Thread.sleep(1000);
             MessageStore store = MessageStoreFactory.getInstance().getMessageStore(MessageStoreType.DATABASE);
             Map<URI, Message> messages = store.getAllMessages("TEST");
+            messages = store.getAllMessages("TEST");
+            Iterator<Message> iter=messages.values().iterator();
+            while (iter.hasNext()) {
+                Message message=iter.next();
+                String bodyFromStore = new String(message.getBody().getContents());
+                System.out.println("Body=" + bodyFromStore);
+            }
             System.out.println("Getting message for classification TEST:" + messages);
             assertEquals(1, messages.size());