[jbpm-commits] JBoss JBPM SVN: r2969 - jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor.

[do-not-reply at jboss.org]

Author: alex.guizar at jboss.com
Date: 2008-11-17 19:50:30 -0500 (Mon, 17 Nov 2008)
New Revision: 2969

Added:
   jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/JobExecutorTests.java
   jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/MultiJobExecutorTest.java
Log:
applied JBPM-1072 changes to soa branch

Added: jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/JobExecutorTests.java
===================================================================
--- jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/JobExecutorTests.java	                        (rev 0)
+++ jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/JobExecutorTests.java	2008-11-18 00:50:30 UTC (rev 2969)
@@ -0,0 +1,17 @@
+package org.jbpm.job.executor;
+
+import junit.framework.Test;
+import junit.framework.TestSuite;
+
+public class JobExecutorTests {
+
+  public static Test suite() {
+    TestSuite suite = new TestSuite("Test for org.jbpm.job.executor");
+    // $JUnit-BEGIN$
+    suite.addTestSuite(JobExecutorDbTest.class);
+    suite.addTestSuite(MultiJobExecutorTest.class);
+    // $JUnit-END$
+    return suite;
+  }
+
+}

Added: jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/MultiJobExecutorTest.java
===================================================================
--- jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/MultiJobExecutorTest.java	                        (rev 0)
+++ jbpm3/branches/jpdl-3.2.2-SOA-4.2/jpdl/jar/src/test/java/org/jbpm/job/executor/MultiJobExecutorTest.java	2008-11-18 00:50:30 UTC (rev 2969)
@@ -0,0 +1,166 @@
+package org.jbpm.job.executor;
+
+import java.sql.SQLException;
+
+import junit.framework.TestCase;
+
+import org.jbpm.JbpmConfiguration;
+import org.jbpm.JbpmContext;
+import org.jbpm.command.CommandService;
+import org.jbpm.command.SignalCommand;
+import org.jbpm.command.StartProcessInstanceCommand;
+import org.jbpm.command.impl.CommandServiceImpl;
+import org.jbpm.graph.def.ActionHandler;
+import org.jbpm.graph.def.ProcessDefinition;
+import org.jbpm.graph.exe.ExecutionContext;
+import org.jbpm.graph.exe.ProcessInstance;
+
+/**
+ * Test case for JBPM-1072.
+ * @author Jiri Pechanec
+ */
+public class MultiJobExecutorTest extends TestCase {
+
+  private static final int EXECUTOR_COUNT = 20;
+  public static final String PROCESS_NAME = "TestProcess";
+
+  private JobExecutor[] executors = new JobExecutor[EXECUTOR_COUNT];
+
+  private static JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();
+  private static CommandService commandService = new CommandServiceImpl(jbpmConfiguration);
+
+  public static final String PROCESS_DEFINITION = "<?xml version='1.0' encoding='UTF-8'?>"
+      + "<process-definition name='TestProcess'>"
+      + "<event type='process-end'>"
+      + "<action name='endAction' class='"
+      + EndAction.class.getName()
+      + "' />"
+      + "</event>"
+      + "<start-state name='start-state1'>"
+      + "<transition to='Service 1'></transition>"
+      + "</start-state>"
+      + "<node name='Service 1'>"
+      + "<action name='esbAction' "
+      + "class='"
+      + SimpleAction.class.getName()
+      + "'>"
+      + "</action>"
+      + "<transition to='Service 2'></transition>"
+      + "</node>"
+      + "<node name='Service 2' async='true'>"
+      + "<action name='esbAction' "
+      + "class='"
+      + SimpleAction2.class.getName()
+      + "'>"
+      + "</action>"
+      + "<transition to='end-state1'></transition>"
+      + "</node>"
+      + "<end-state name='end-state1'></end-state>"
+      + "</process-definition>";
+
+  protected void setUp() throws SQLException {
+    jbpmConfiguration.createSchema();
+
+    // deploy process definition
+    JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
+    try {
+      jbpmContext.deployProcessDefinition(ProcessDefinition.parseXmlString(PROCESS_DEFINITION));
+      System.out.println("Isolation " + jbpmContext.getConnection().getTransactionIsolation());
+    }
+    finally {
+      jbpmContext.close();
+    }
+  }
+
+  public void testMultipleExecutors() {
+    // start job executors
+    for (int i = 0; i < executors.length; i++) {
+      executors[i] = (JobExecutor) JbpmConfiguration.Configs.getObjectFactory().createObject(
+          "jbpm.job.executor");
+      executors[i].setName("JbpmJobExecutor/" + (i + 1));
+      executors[i].start();
+    }
+
+    // kick off process instance
+    StartProcessInstanceCommand startCommand = new StartProcessInstanceCommand();
+    startCommand.setProcessName(PROCESS_NAME);
+    ProcessInstance pi = (ProcessInstance) commandService.execute(startCommand);
+
+    // signal service 1
+    SignalCommand signalCommand = new SignalCommand();
+    signalCommand.setTokenId(pi.getRootToken().getId());
+    commandService.execute(signalCommand);
+
+    // wait for process end
+    EndAction.waitFor();
+
+    // stop job executors
+    for (int i = executors.length - 1; i >= 0; i--) {
+      try {
+        executors[i].stopAndJoin();
+      }
+      catch (InterruptedException e) {
+        // continue to next executor
+      }
+    }
+
+    assertEquals(1, SimpleAction2.getExecutionCount());
+  }
+
+  protected void tearDown() {
+    jbpmConfiguration.dropSchema();
+  }
+
+  public static class SimpleAction implements ActionHandler {
+
+    private static final long serialVersionUID = -9065054081909009083L;
+
+    public void execute(ExecutionContext ctx) throws Exception {
+      System.out.println("Action 1");
+    }
+
+  }
+
+  public static class SimpleAction2 implements ActionHandler {
+
+    private static int executionCount = 0;
+
+    private static final long serialVersionUID = -9065054081909009083L;
+
+    public void execute(ExecutionContext ctx) throws Exception {
+      System.out.println("Action 2: " + incrementCount());
+      ctx.getNode().leave(ctx);
+    }
+
+    private static synchronized int incrementCount() {
+      return ++executionCount;
+    }
+
+    public static synchronized int getExecutionCount() {
+      return executionCount;
+    }
+  }
+
+  public static class EndAction implements ActionHandler {
+
+    private static final Object monitor = new Object();
+
+    private static final long serialVersionUID = 1L;
+
+    public void execute(ExecutionContext executionContext) throws Exception {
+      synchronized (monitor) {
+        monitor.notify();
+      }
+    }
+
+    public static void waitFor() {
+      try {
+        synchronized (monitor) {
+          monitor.wait(60000);
+        }
+      }
+      catch (InterruptedException e) {
+      }
+    }
+  }
+}