Fstachecki: /* UserTask */

2018-04-19T19:45:13Z

UserTask

New page

{{Cat|Private}}
=Exercises=
==Inclusive Gateway==
[[File:Eclipse01InclusiveGateway.png]]
*default path may not work (Eclipse bug)

<source lang="java">
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws Exception {
/**
* A salesman will get a 100 bonus if his sales is over 1000
* if his sales is over 5000 he will get a car as well
* if his sales is over 10000 he will be made a Managing Director
*
* 1. Create appropriate gateway and process variables
* 2. Create a test which checks appropriate End events (NodeTriggered)
*/
createRuntimeManager("inclusive.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("sales", 15000);
ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn", params);
//Ends 1 to 3 will be reached
assertNodeTriggered(processInstance.getId(),"End1");
assertNodeTriggered(processInstance.getId(),"End2");
assertNodeTriggered(processInstance.getId(),"End3");

assertProcessInstanceCompleted(processInstance.getId(), ksession);

}
}
</source>

==Parallel Gateway==
[[File:Eclipse02ParallelGateway.png]]

* no variables, no params (remove params attribute from startProcess method)
* just 2 script tasks
* change second parallel gateway type to '''Converging'''

<source lang="java">
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws Exception {
createRuntimeManager("BPMN2-Parallel.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

/**
* Trip booking requires booking hotel and the flight
* These things can be done concurrently (use parallel gateway)
*
* Advanced:
* If booking of a hotel or flight fails, create a mechanism for cancelling the reservation (use exclusive gateway)
*/

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn");
assertNodeTriggered(processInstance.getId(),"Book Hotel");
assertNodeTriggered(processInstance.getId(),"Book Flight");
assertProcessInstanceCompleted(processInstance.getId(), ksession);

}
}
</source>

==Parallel Gateway - Compensation==
[[File:Eclipse02ParallelAdvanced.png]]

* we want to check the result of booking
* 2 process variables: hotelBooked:boolean, flightBooked:boolean
* conditions:
** return (hotelBooked && flightBooked);
** return (! hotelBooked && ! flightBooked);
** return (hotelBooked && ! flightBooked);
** return (! hotelBooked && flightBooked);

<source lang="java">
public class ProcessTestAdvanced extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws Exception {
createRuntimeManager("ParallelAdvanced.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("hotelBooked", false);
params.put("flightBooked", false);
ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.advanced",params);

assertNodeTriggered(processInstance.getId(),"Book Hotel");
assertNodeTriggered(processInstance.getId(),"Book Flight");
assertProcessInstanceCompleted(processInstance.getId(), ksession);
assertNodeTriggered(processInstance.getId(),"both failed");

}

@Test
public void testProcessBothOK() throws Exception {
createRuntimeManager("ParallelAdvanced.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("hotelBooked", true);
params.put("flightBooked", true);
ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.advanced",params);

// System.out.println(params.get("hotelBooked"));
// System.out.println(params.get("hotelBooked"));

assertNodeTriggered(processInstance.getId(),"Book Hotel");
assertNodeTriggered(processInstance.getId(),"Book Flight");
assertProcessInstanceCompleted(processInstance.getId(), ksession);
assertNodeTriggered(processInstance.getId(),"both OK");

}
}
</source>

==Timer - delay==
* Timer event has two expressions sections:
** first - specific time
** second - specific cycle
:[[File:ClipCapIt-150205-092359.PNG]]

* If you can't connect script task to intermediate timer event use context menu:
:[[File:ClipCapIt-150205-115534.PNG]]

Scenario: A boyfriend sends an SMS message for his girlfriend. She waits 5s and sends reply SMS message.

[[File:Eclipse03Timer.png]]

* timer - time duration 5s

<source lang="java">
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws InterruptedException {
RuntimeManager manager = createRuntimeManager("sample.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.hello");

assertNodeTriggered(processInstance.getId(), "Receive SMS");

assertProcessInstanceActive(processInstance.getId(), ksession);
// now wait for 2 seconds for timer to trigger
Thread.sleep(2000);
assertProcessInstanceActive(processInstance.getId(), ksession);

Thread.sleep(4000);
//Here process instance is no longer active
//assertProcessInstanceActive(processInstance.getId(), ksession);

// check whether the process instance has completed successfully
assertProcessInstanceCompleted(processInstance.getId(), ksession);

manager.disposeRuntimeEngine(engine);
manager.close();
}

}
</source>

===05.2_timer_boundary_interrupting_time===
*To add boundary event drag and drop event from boundary section - not from Intermediate catching section.
:[[File:ClipCapIt-150205-002710.PNG]]

===05.3_timer_boundary_non_interrupting_cycle===
timer cycle 500ms###1s is 500ms initial delay + 1s delay -after 0.5s every 1s

==Loop ==
[[File:EclipseLoopExample.png]]

* Init task
kcontext.setVariable("i", 0);
* loop task
System.out.println("i = " + i);
kcontext.setVariable("i", i+1);
* done task
System.out.println("Loop completed");
* conditions
return i < count;

return true; (change to default flow)

<source lang="java">
public class LoopingExample extends JbpmJUnitBaseTestCase {
@Test
public void testProcess() throws MalformedURLException {
createRuntimeManager("Looping.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("count", 5);
ksession.startProcess("com.sample.looping", params);
}
}
</source>

==Multi instance==
[[File:EclipseMIExample.png]]
* Say Hi task
System.out.println(kcontext.getVariable("mi_person_name") );
<source lang="java">
public class MultipleInstanceExample extends JbpmJUnitBaseTestCase {
@Test
public void testProcess(){
createRuntimeManager("multipleinstance.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();
Map<String, Object> params = new HashMap<String, Object>();
List<String> list = new ArrayList<String>();
list.add("Bernard");
list.add("Greg");
list.add("Phil");
params.put("list", list);
ksession.startProcess("com.sample.multipleinstance", params);
}
}
</source>
* to set MI attributes change editor to '''BPMN2 Process Editor'''
[[File:EclipseMIExampleBPMN2ProcessEditorView.png]]
* 07.1_exercise
**copy BPMN file from 07_looping_multiinstance and add gateway:
:[[File:MIsendEmail.png]]
**Sent e-mail task:
System.out.println("E-mail sent to: " + kcontext.getVariable("mi_person_name") );
** conditions
return kcontext.getVariable("mi_person_name") != "Greg";

==Boundary events==
* Message event in jBPM is implemented as signal event
//If you send a message, it will be Message-ID
ksession.signalEvent("Message-BookingCancelation",null,processInstance.getId());

[[File:jBPMevents.png]]

https://www.packtpub.com/networking-and-servers/jbpm-6-developer-guide

===Message boundary exercise===
* Create new jBPM Project (not MAVEN, not KJAR)
:[[File:ClipCapIt-150205-173728.PNG]]
* Add process variable (string)
:[[File:ClipCapIt-150205-174219.PNG]]
* Define Message Event
:[[File:ClipCapIt-150205-174434.PNG]]
** Assign target to process variable
:[[File:ClipCapIt-150205-174518.PNG]]
* Write JUnit test
** add add '''throws Exception''' to test method (to use Thread.sleep):
@Test
public void testProcess() throws Exception {

* final code
<source lang="java">
package com.sample;

import org.jbpm.test.JbpmJUnitBaseTestCase;
import org.junit.Test;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.manager.RuntimeManager;
import org.kie.api.runtime.process.ProcessInstance;

/**
* This is a sample file to test a process.
*/
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws Exception {
RuntimeManager manager = createRuntimeManager("sample.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.hello");
// check whether the process instance has completed successfully

Thread.sleep(1000);
ksession.signalEvent("Message-CancelMessage",null,processInstance.getId());
assertProcessInstanceCompleted(processInstance.getId(), ksession);
//assertNodeTriggered(processInstance.getId(), "Hello");

manager.disposeRuntimeEngine(engine);
manager.close();
}

}
</source>

* Change boundary event type to non interrupting and change test:
<source lang="java">
@Test
public void testProcess() throws Exception {
RuntimeManager manager = createRuntimeManager("sample.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.hello");

Thread.sleep(1000);
ksession.signalEvent("Message-CancelMessage",null,processInstance.getId());
Thread.sleep(1000);
ksession.signalEvent("Message-CancelMessage",null,processInstance.getId());
Thread.sleep(10000);
manager.disposeRuntimeEngine(engine);
manager.close();
</source>

* Console window:
inside
message received
message received
after

===Error boundary exercise===
* Create process with error events
:[[File:ClipCapIt-150205-192044.PNG]]
* process variables:
** ok:Boolean (for a gateway)
** errorVar:Integer
* Add Error Event details
** Error End Event
:[[File:ClipCapIt-150205-194303.PNG]]
** Error Boundary Intermediate Event
:[[File:ClipCapIt-150205-194423.PNG]]
* JUnit code
<source lang="java">
package com.sample;

import java.util.HashMap;
import java.util.Map;

import org.jbpm.test.JbpmJUnitBaseTestCase;
import org.junit.Test;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.manager.RuntimeManager;
import org.kie.api.runtime.process.ProcessInstance;

/**
* This is a sample file to test a process.
*/
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcessNoErrors() {
RuntimeManager manager = createRuntimeManager("ErrorBoundary.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("ok", true);

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.hello", params);

// check whether the process instance has completed successfully
assertProcessInstanceCompleted(processInstance.getId(), ksession);

manager.disposeRuntimeEngine(engine);
manager.close();
}

@Test
public void testProcessError() {
RuntimeManager manager = createRuntimeManager("ErrorBoundary.bpmn");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("ok", false); //trigger error

ProcessInstance processInstance = ksession.startProcess("com.sample.bpmn.hello", params);

// check whether the process instance has completed successfully
assertProcessInstanceCompleted(processInstance.getId(), ksession);

manager.disposeRuntimeEngine(engine);
manager.close();
}

}
</source>

==Event-Based Gateway==
* Create diagram
:[[File:ClipCapIt-150205-232601.PNG]]
* JUnit test
<source lang="java">
package com.nobleprog;

import org.jbpm.process.instance.impl.demo.SystemOutWorkItemHandler;
import org.jbpm.test.JbpmJUnitBaseTestCase;
import org.junit.Test;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.process.ProcessInstance;

public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcessMessage1() throws Exception {

createRuntimeManager("EventBasedGateway-Loan.bpmn2");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ProcessInstance processInstance = ksession.startProcess("com.sample.test");
ksession.signalEvent("Message-Message_1", null, processInstance.getId());

assertProcessInstanceCompleted(processInstance.getId(), ksession);

}

@Test
public void testProcessTimer() throws Exception {

createRuntimeManager("EventBasedGateway-Loan.bpmn2");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ProcessInstance processInstance = ksession.startProcess("com.sample.test");
Thread.sleep(6000);
assertProcessInstanceCompleted(processInstance.getId(), ksession);

}

}
</source>

==Compensation==
* Create diagram
:[[File:ClipCapIt-150206-000714.PNG]]
:* to add compensation boundary event drag and drop empty boundary event and change event definition
:* then drag and drop script task and connect boundary event with the task using association
* JUnit code
<source lang="java">
package com.sample;

import java.util.HashMap;
import java.util.Map;

import org.jbpm.test.JbpmJUnitBaseTestCase;
import org.junit.Test;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.manager.RuntimeManager;
import org.kie.api.runtime.process.ProcessInstance;

/**
* This is a sample file to test a process.
*/
public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() {

RuntimeManager manager = createRuntimeManager("BPMN2-Compensation-IntermediateThrowEvent.bpmn2");
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

Map<String, Object> params = new HashMap<String, Object>();
params.put("x", 10);

System.out.println("Initialized value: " + params.get("x"));
ProcessInstance processInstance = ksession.startProcess("CompensateIntermediateThrowEvent", params);

// check whether the process instance has completed successfully
assertProcessInstanceCompleted(processInstance.getId(), ksession);

manager.disposeRuntimeEngine(engine);
manager.close();
}
}
</source>

<source lang="xml">
<?xml version="1.0" encoding="UTF-8"?>
<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:tns="http://www.jboss.org/drools" xmlns="http://www.jboss.org/drools" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd http://www.jboss.org/drools drools.xsd http://www.bpsim.org/schemas/1.0 bpsim.xsd" id="Definition" expressionLanguage="http://www.mvel.org/2.0" targetNamespace="http://www.example.org/MinimalExample" typeLanguage="http://www.java.com/javaTypes">
<bpmn2:itemDefinition id="_xItem" structureRef="String"/>
<bpmn2:itemDefinition id="_Integer" structureRef="Integer"/>
<bpmn2:process id="CompensateIntermediateThrowEvent" tns:version="1" tns:packageName="defaultPackage" tns:adHoc="false" name="Compensate Intermediate Throw Event Process" isExecutable="true" processType="Private">
<bpmn2:property id="x" itemSubjectRef="_Integer"/>
<bpmn2:startEvent id="_1" name="StartProcess">
<bpmn2:outgoing>_1-_2</bpmn2:outgoing>
</bpmn2:startEvent>
<bpmn2:sequenceFlow id="_1-_2" tns:priority="1" name="" sourceRef="_1" targetRef="_2"/>
<bpmn2:scriptTask id="_2" name="Task">
<bpmn2:incoming>_1-_2</bpmn2:incoming>
<bpmn2:outgoing>SequenceFlow_1</bpmn2:outgoing>
<bpmn2:script>System.out.println("Inside (before compensation): " + x=99);</bpmn2:script>
</bpmn2:scriptTask>
<bpmn2:boundaryEvent id="_10" name="CompensateEvent" attachedToRef="_2" cancelActivity="false">
<bpmn2:compensateEventDefinition id="CompensateEventDefinition_2" activityRef="_2"/>
</bpmn2:boundaryEvent>
<bpmn2:scriptTask id="_11" name="Compensate" isForCompensation="true">
<bpmn2:script>System.out.println("After compensation: " + x);</bpmn2:script>
</bpmn2:scriptTask>
<bpmn2:sequenceFlow id="SequenceFlow_1" tns:priority="1" name="" sourceRef="_2" targetRef="_4"/>
<bpmn2:intermediateThrowEvent id="_4" name="CompensateEvent">
<bpmn2:incoming>SequenceFlow_1</bpmn2:incoming>
<bpmn2:outgoing>_4-_5</bpmn2:outgoing>
<bpmn2:compensateEventDefinition id="CompensateEventDefinition_1" activityRef="_2"/>
</bpmn2:intermediateThrowEvent>
<bpmn2:sequenceFlow id="_4-_5" tns:priority="1" name="" sourceRef="_4" targetRef="_5"/>
<bpmn2:endEvent id="_5" name="EndEvent">
<bpmn2:incoming>_4-_5</bpmn2:incoming>
</bpmn2:endEvent>
<bpmn2:association id="_10-_11" sourceRef="_10" targetRef="_11"/>
</bpmn2:process>
<bpmndi:BPMNDiagram id="BPMNDiagram_1">
<bpmndi:BPMNPlane id="BPMNPlane_Process_1" bpmnElement="CompensateIntermediateThrowEvent">
<bpmndi:BPMNShape id="BPMNShape_StartEvent_1" bpmnElement="_1">
<dc:Bounds height="36.0" width="36.0" x="50.0" y="57.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="BPMNShape_IntermediateThrowEvent_1" bpmnElement="_4">
<dc:Bounds height="36.0" width="36.0" x="340.0" y="57.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="BPMNShape_EndEvent_1" bpmnElement="_5">
<dc:Bounds height="36.0" width="36.0" x="490.0" y="57.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="BPMNShape_ScriptTask_1" bpmnElement="_2">
<dc:Bounds height="50.0" width="110.0" x="136.0" y="50.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="BPMNShape_BoundaryEvent_1" bpmnElement="_10">
<dc:Bounds height="36.0" width="36.0" x="173.0" y="82.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="BPMNShape_ScriptTask_2" bpmnElement="_11">
<dc:Bounds height="50.0" width="110.0" x="136.0" y="150.0"/>
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge id="BPMNEdge_SequenceFlow_1" bpmnElement="_1-_2" sourceElement="BPMNShape_StartEvent_1" targetElement="BPMNShape_ScriptTask_1">
<di:waypoint xsi:type="dc:Point" x="86.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="108.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="108.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="136.0" y="75.0"/>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="BPMNEdge_SequenceFlow_4" bpmnElement="_4-_5" sourceElement="BPMNShape_IntermediateThrowEvent_1" targetElement="BPMNShape_EndEvent_1">
<di:waypoint xsi:type="dc:Point" x="376.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="427.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="427.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="490.0" y="75.0"/>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="BPMNEdge_Association_1" bpmnElement="_10-_11" sourceElement="BPMNShape_BoundaryEvent_1" targetElement="BPMNShape_ScriptTask_2">
<di:waypoint xsi:type="dc:Point" x="191.0" y="118.0"/>
<di:waypoint xsi:type="dc:Point" x="191.0" y="132.0"/>
<di:waypoint xsi:type="dc:Point" x="191.0" y="132.0"/>
<di:waypoint xsi:type="dc:Point" x="191.0" y="150.0"/>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="BPMNEdge_SequenceFlow_5" bpmnElement="SequenceFlow_1" sourceElement="BPMNShape_ScriptTask_1" targetElement="BPMNShape_IntermediateThrowEvent_1">
<di:waypoint xsi:type="dc:Point" x="246.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="288.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="288.0" y="75.0"/>
<di:waypoint xsi:type="dc:Point" x="340.0" y="75.0"/>
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</bpmn2:definitions>
</source>

==UserTask - not working==
* Create new jBPM project
* Create BPMN diagram
:[[File:ClipCapIt-180419-173425.PNG]]
** set gateway type to diverging
** add approved:boolean local process variable
** add conditions after the gateway
** add script task script

==Work Item==
Scenario: We need to get Order data to issue an invoice using external system.

[[File:Eclipse06WorkItem.png]]

Project Explorer

[[File:Eclipse06WorkItemFoderStructure.png]]

===Work Item Definition (GetOrder.wid)===

<source lang="java">
import org.drools.core.process.core.datatype.impl.type.StringDataType;
[
[
"name" : "GetOrder",
"parameters" : [
"orderId" : new StringDataType(),
"orderTotal" : new StringDataType(),
],
"displayName" : "GetOrder",
"icon" : "icons/getoutlinetitle.gif"
]
]
</source>

===drools.rulebase.conf===

<source lang="java">
drools.workDefinitions = GetOrder.wid
</source>

===Work Item Handler===

<source lang="java">
package com.nobleprog;

import java.util.HashMap;
import java.util.Map;

import org.kie.api.runtime.process.WorkItem;
import org.kie.api.runtime.process.WorkItemHandler;
import org.kie.api.runtime.process.WorkItemManager;

public class GetOrderWorkItemHandler implements WorkItemHandler {
public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {

// extract parameters
String orderId = (String) workItem.getParameter("orderId");
Map<String, Object> result = new HashMap<String,Object>();
result.put("orderTotal","12000");
System.out.println("Retriving order information (mock service) for orderId:" + orderId);

manager.completeWorkItem(workItem.getId(), result);
}

public void abortWorkItem(WorkItem workItem, WorkItemManager manager) {
// Do nothing, notifications cannot be aborted
}
}
</source>

===ProcessTest.java===

<source lang="java">

package com.nobleprog;
import java.util.HashMap;
import java.util.Map;

import com.nobleprog.GetOrderWorkItemHandler;

import org.jbpm.test.JbpmJUnitBaseTestCase;
import org.junit.Test;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.manager.RuntimeEngine;
import org.kie.api.runtime.process.ProcessInstance;

public class ProcessTest extends JbpmJUnitBaseTestCase {

@Test
public void testProcess() throws Exception {
String[] processes = new String[]{"IssueInvoice.bpmn2"};
createRuntimeManager(processes);
RuntimeEngine engine = getRuntimeEngine(null);
KieSession ksession = engine.getKieSession();

ksession.getWorkItemManager().registerWorkItemHandler("GetOrder", new GetOrderWorkItemHandler());
Map<String, Object> params = new HashMap<String, Object>();
params.put("orderId", "15");
ProcessInstance processInstance = ksession.startProcess("com.sample.test", params);

assertProcessInstanceCompleted(processInstance.getId(), ksession);
}
}
</source>

==Using Eclipse with Workbench==
* Eclipse -> KIE Workbench
* KIE Workbench -> Eclipse
** [KIE] Authoring/Administration
** [Eclipse] Right click/Team/Pull

JBPM 6 Filip - Revision history

Fstachecki: /* UserTask */