[jbpm-commits] JBoss JBPM SVN: r2819 - jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms.

[do-not-reply at jboss.org]

Author: thomas.diesler at jboss.com
Date: 2008-11-08 10:23:32 -0500 (Sat, 08 Nov 2008)
New Revision: 2819

Modified:
   jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms/JmsMessageTest.java
Log:
[JBPM-1811] JmsMessageTest fails intermitently on HSQLDB

Modified: jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms/JmsMessageTest.java
===================================================================
--- jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms/JmsMessageTest.java	2008-11-08 15:12:05 UTC (rev 2818)
+++ jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms/JmsMessageTest.java	2008-11-08 15:23:32 UTC (rev 2819)
@@ -60,7 +60,8 @@
      return new IntegrationTestSetup(JmsMessageTest.class, "enterprise-test.war");
   }
 
-  protected void setUp() throws Exception {
+  protected void setUp() throws Exception 
+  {
     if (commandServiceHome == null) {
       Context initialContext = new InitialContext();
       try {
@@ -74,13 +75,15 @@
     log.info("### " + getName() + " started ###");
   }
 
-  protected void tearDown() throws Exception {
+  protected void tearDown() throws Exception 
+  {
     log.info("### " + getName() + " done ###");
     commandService = null;
     EventCallback.clear();
   }
 
-  public void testAsyncNode() {
+  public void testAsyncNode() 
+  {
     deployProcess("<process-definition name='node'>"
         + "  <event type='process-end'>"
         + "    <action expression='#{eventCallback.processEnd}'/>"
@@ -95,10 +98,11 @@
         + "</process-definition>");
     long processId = launchProcess("node").getId();
     EventCallback.waitForEvent(Event.EVENTTYPE_PROCESS_END);
-    assertTrue(hasProcessEnded(processId));
+    assertTrue("Process has ended", hasProcessEnded(processId));
   }
 
-  public void testAsyncAction() {
+  public void testAsyncAction() 
+  {
     deployProcess("<process-definition name='action'>"
         + "  <start-state name='start'>"
         + "    <transition to='a' />"
@@ -120,10 +124,11 @@
     EventCallback.waitForEvent(Event.EVENTTYPE_NODE_ENTER);
     EventCallback.waitForEvent(Event.EVENTTYPE_NODE_LEAVE);
     EventCallback.waitForEvent(Event.EVENTTYPE_TRANSITION);
-    assertTrue(hasProcessEnded(processId));
+    assertTrue("Process has ended", hasProcessEnded(processId));
   }
 
-  public void testAsyncSequence() {
+  public void testAsyncSequence() 
+  {
     deployProcess("<process-definition name='sequence'>"
         + "  <event type='process-end'>"
         + "    <action expression='#{eventCallback.processEnd}'/>"
@@ -150,10 +155,11 @@
         + "</process-definition>");
     long processId = launchProcess("sequence").getId();
     EventCallback.waitForEvent(Event.EVENTTYPE_PROCESS_END);
-    assertTrue(hasProcessEnded(processId));
+    assertTrue("Process has ended", hasProcessEnded(processId));
   }
 
-  public void testAsyncFork() {
+  public void testAsyncFork() throws Exception 
+  {
     deployProcess("<process-definition name='fork'>"
         + "  <event type='process-end'>"
         + "    <action expression='#{eventCallback.processEnd}'/>"
@@ -190,10 +196,12 @@
         + "</process-definition>");
     long processId = launchProcess("fork").getId();
     EventCallback.waitForEvent(Event.EVENTTYPE_PROCESS_END);
+    Thread.sleep(1000);
     assertTrue("Process has ended", hasProcessEnded(processId));
   }
 
-  public void testAsyncExecutions() {
+  public void testAsyncExecutions() 
+  {
     deployProcess("<process-definition name='execution'>"
         + "  <event type='process-end'>"
         + "    <action expression='#{eventCallback.processEnd}' />"