[jbpm-commits] JBoss JBPM SVN: r2819 - jbpm3/branches/jbpm-3.3.0.GA/modules/enterprise/jar/src/test/java/org/jbpm/msg/jms.
Author: thomas.diesler(a)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}'
/>"