[jboss-svn-commits] JBL Code SVN: r14304 - labs/jbossesb/trunk/product/services/jbossesb/src/test/java/org/jboss/soa/esb/persistence/tests.

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

Author: kurt.stam at jboss.com
Date: 2007-08-16 09:17:10 -0400 (Thu, 16 Aug 2007)
New Revision: 14304

Modified:
   labs/jbossesb/trunk/product/services/jbossesb/src/test/java/org/jboss/soa/esb/persistence/tests/ScheduledRedeliveryUnitTest.java
Log:
Mark seems to have a timing issue. Trying to reduce the number of messages sent.

Modified: labs/jbossesb/trunk/product/services/jbossesb/src/test/java/org/jboss/soa/esb/persistence/tests/ScheduledRedeliveryUnitTest.java
===================================================================
--- labs/jbossesb/trunk/product/services/jbossesb/src/test/java/org/jboss/soa/esb/persistence/tests/ScheduledRedeliveryUnitTest.java	2007-08-16 12:33:02 UTC (rev 14303)
+++ labs/jbossesb/trunk/product/services/jbossesb/src/test/java/org/jboss/soa/esb/persistence/tests/ScheduledRedeliveryUnitTest.java	2007-08-16 13:17:10 UTC (rev 14304)
@@ -24,6 +24,7 @@
 import java.net.URI;
 import java.sql.Connection;
 import java.sql.Statement;
+import java.util.Date;
 import java.util.Map;
 
 import junit.framework.JUnit4TestAdapter;
@@ -96,7 +97,13 @@
             URI uid = createMessages(numberOfMessages, service, store);
             Map<URI, Message> messageMap = store.getAllMessages(RedeliverStore.CLASSIFICATION_RDLVR); 
             assertEquals(messageMap.size(), numberOfMessages);
+            System.out.println(new Date());
             runTestConfig("config-01.xml", 5000);
+            System.out.println(new Date());
+            Map<URI,Message> leftOverMsgs = store.getAllMessages(MessageStore.CLASSIFICATION_RDLVR);
+            System.out.println("Number of messages still in RDLVR store: " + leftOverMsgs.size());
+            Map<URI,Message> dlqMsgs = store.getAllMessages(MessageStore.CLASSIFICATION_DLQ);
+            System.out.println("Number of messages still in DLQ store: " + dlqMsgs.size());
             Message message2 = store.getMessage(uid); 
             assertNull(message2);
         } catch (Exception e) {