[jboss-svn-commits] JBL Code SVN: r34471 - in labs/jbossrules/trunk/drools-process/drools-process-task/src: main/java/org/drools/task/service/hornetq and 6 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Mon Aug 2 17:00:53 EDT 2010
Author: kurt.stam at jboss.com
Date: 2010-08-02 17:00:51 -0400 (Mon, 02 Aug 2010)
New Revision: 34471
Modified:
labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/TaskServer.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/mina/BaseMinaTaskServer.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/main/resources/META-INF/persistence.xml
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/hornetq/WSHumanTaskHandlerHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/mina/WSHumanTaskHandlerMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/IcalHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskLifeCycleHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceCommentsAndAttachmentsHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceDeadlinesHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEscalationHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEventMessagingHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceLifeCycleHornetQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/IcalMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskLifeCycleMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceCommentsAndAttachmentsMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceDeadlinesMinaQTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEscalationMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEventMessagingMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceLifeCycleMinaTest.java
labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceMinaTest.java
Log:
These unittests fail intermittent under load when the 'server' does not come up in the hardcoded 500 ms. Now it waits till it it up bu checking the isRunning flag.
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/TaskServer.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/TaskServer.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/TaskServer.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -20,5 +20,6 @@
public abstract void start() throws Exception;
public abstract void stop() throws Exception;
+ public abstract boolean isRunning();
}
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -176,4 +176,8 @@
consumer.close();
}
}
+
+ public boolean isRunning() {
+ return running;
+ }
}
\ No newline at end of file
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/mina/BaseMinaTaskServer.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/mina/BaseMinaTaskServer.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/task/service/mina/BaseMinaTaskServer.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -56,8 +56,7 @@
}
public void start() throws IOException {
- running = true;
-
+
acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast( "logger",
@@ -69,6 +68,7 @@
acceptor.getSessionConfig().setReadBufferSize( 2048 );
acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
acceptor.bind( new InetSocketAddress( "127.0.0.1", port ) );
+ running = true;
}
public IoAcceptor getIoAcceptor() {
@@ -76,7 +76,11 @@
}
public void stop() {
+ running = false;
acceptor.dispose();
- running = false;
}
+
+ public boolean isRunning() {
+ return running;
+ }
}
\ No newline at end of file
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/main/resources/META-INF/persistence.xml
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/main/resources/META-INF/persistence.xml 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/main/resources/META-INF/persistence.xml 2010-08-02 21:00:51 UTC (rev 34471)
@@ -44,7 +44,7 @@
<property name="hibernate.connection.autocommit" value="false" />
<property name="hibernate.max_fetch_depth" value="3"/>
<property name="hibernate.hbm2ddl.auto" value="create" />
- <property name="hibernate.show_sql" value="true" />
+ <property name="hibernate.show_sql" value="false" />
</properties>
</persistence-unit>
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/hornetq/WSHumanTaskHandlerHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/hornetq/WSHumanTaskHandlerHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/hornetq/WSHumanTaskHandlerHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -35,7 +35,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
setClient(new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener()))));
getClient().connect("127.0.0.1", 5446);
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/mina/WSHumanTaskHandlerMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/mina/WSHumanTaskHandlerMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/mina/WSHumanTaskHandlerMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -35,7 +35,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the Mina Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
setClient(new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener()))));
getClient().connect("127.0.0.1", 9123);
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/IcalHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/IcalHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/IcalHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -21,11 +21,13 @@
import org.drools.task.service.TaskClient;
import org.drools.util.ChainedProperties;
import org.drools.util.ClassLoaderUtil;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
import org.subethamail.wiser.Wiser;
public class IcalHornetQTest extends IcalBaseTest {
- @Override
+ @Override @BeforeClass
protected void setUp() throws Exception {
super.setUp();
@@ -36,7 +38,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
@@ -48,6 +54,7 @@
getWiser().start();
}
+ @AfterClass
protected void tearDown() throws Exception {
super.tearDown();
client.disconnect();
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskLifeCycleHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskLifeCycleHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskLifeCycleHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
client.connect("127.0.0.1", 5446);
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceCommentsAndAttachmentsHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceCommentsAndAttachmentsHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceCommentsAndAttachmentsHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceDeadlinesHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceDeadlinesHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceDeadlinesHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -39,7 +39,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEscalationHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEscalationHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEscalationHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEventMessagingHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEventMessagingHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceEventMessagingHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -29,7 +29,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,12 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread( server );
thread.start();
- Thread.sleep( 500 );
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
client.connect("127.0.0.1", 5446);
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceLifeCycleHornetQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceLifeCycleHornetQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/hornetq/TaskServiceLifeCycleHornetQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,11 @@
server = new HornetQTaskServer(taskService, 5446);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the HornetQTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new HornetQTaskClientConnector("client 1",
new HornetQTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/IcalMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/IcalMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/IcalMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -39,7 +39,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskLifeCycleMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskLifeCycleMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskLifeCycleMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -31,7 +31,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
client.connect("127.0.0.1", 9123);
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceCommentsAndAttachmentsMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceCommentsAndAttachmentsMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceCommentsAndAttachmentsMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -28,7 +28,11 @@
server = new MinaTaskServer( taskService );
Thread thread = new Thread( server );
thread.start();
- Thread.sleep( 500 );
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceDeadlinesMinaQTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceDeadlinesMinaQTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceDeadlinesMinaQTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -44,7 +44,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEscalationMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEscalationMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEscalationMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -31,7 +31,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEventMessagingMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEventMessagingMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceEventMessagingMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -32,7 +32,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceLifeCycleMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceLifeCycleMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceLifeCycleMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -33,7 +33,11 @@
server = new MinaTaskServer(taskService);
Thread thread = new Thread(server);
thread.start();
- Thread.sleep(500);
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceMinaTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceMinaTest.java 2010-08-02 19:05:44 UTC (rev 34470)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/task/service/mina/TaskServiceMinaTest.java 2010-08-02 21:00:51 UTC (rev 34471)
@@ -31,7 +31,11 @@
server = new MinaTaskServer( taskService );
Thread thread = new Thread( server );
thread.start();
- Thread.sleep( 500 );
+ System.out.println("Waiting for the MinaTask Server to come up");
+ while (!server.isRunning()) {
+ System.out.print(".");
+ Thread.sleep( 50 );
+ }
client = new TaskClient(new MinaTaskClientConnector("client 1",
new MinaTaskClientHandler(SystemEventListenerFactory.getSystemEventListener())));
client.connect("127.0.0.1", 9123);
More information about the jboss-svn-commits
mailing list