[JBoss jBPM] - Re: token on tasks instance created at runtime
by steve.j.hall＠tektronix.com
Thanks for posting this question. It helped me look at some alternatives in a test case I had been working on.
The example shows two alternatives:
1. Loding and updating a process at runtime to add a task to a TaskNode, persisting the process change to the database. Later loading the process instance including the new task we added via our program.
2. Adding a task to a TaskNode at runtime, where the task is not defined in the process definition. In the code below see: Task rtTask = new Task("RuntimeTask");
In this example node 'r' is a TaskNode.
I have checked the database and see that the task instances and their variables are persisted as one would hope.
private void deployProcessDefinition(){
// load the process definition from a file
ProcessDefinition processDefinition = ProcessDefinition.parseXmlResource("pm/processdefinition.xml");
assertNotNull("Definition should not be null", processDefinition);
// create a delegate and an event
org.jbpm.instantiation.Delegation del = new org.jbpm.instantiation.Delegation(new com.sample.action.StartPklblTaskActionHandler());
Action actn = new Action(del);
Event evt = new Event(Event.EVENTTYPE_TASK_START);
evt.addAction(actn);
del.setClassName("com.sample.action.StartPklblTaskActionHandler");
del.setConfigType("bean");
// create a task and assign the event
Task pklblTask = new Task("PackingLabel");
pklblTask.setSignalling(true);
pklblTask.setBlocking(true);
pklblTask.addEvent(evt);
// can set a breakpoint here to look at the tasks the process knows about.
Map taskMap = processDefinition.getTaskMgmtDefinition().getTasks();
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
try{
// Deploy and persist to db
jbpmContext.deployProcessDefinition(processDefinition);
jbpmContext.close();
// find and load the process from the database then
// add a task via the program execution and persist to db
jbpmContext = jbpmConfiguration.createJbpmContext();
GraphSession gs = jbpmContext.getGraphSession();
ProcessDefinition pd = gs.findProcessDefinition("hello world", 1);
// get the task node named r
// add a task to it via the API
TaskNode rNode = (TaskNode) pd.getNode("r");
del.setProcessDefinition(pd);
pklblTask.setProcessDefinition(pd);
rNode.addTask(pklblTask);
pklblTask.setTaskMgmtDefinition(pd.getTaskMgmtDefinition());
jbpmContext.close();
} catch(Exception e){
e.printStackTrace();
fail();
}
}
private void emulateUserOne(){
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
try{
// load the process definition
ProcessDefinition pd = findProcessDefinition(jbpmContext, "hello world", 1);
// create a process instance
ProcessInstance pi = new ProcessInstance(pd);
TaskMgmtInstance tmi = pi.getTaskMgmtInstance();
pi.setStart(new Date());
TaskMgmtSession tms = jbpmContext.getTaskMgmtSession();
ContextInstance ci = pi.getContextInstance();
ci.setVariable("lotId", "100009");
Token rootToken = pi.getRootToken();
ExecutionContext exc = new ExecutionContext(rootToken);
System.out.println("currentNode: " + rootToken.getNode().getName());
TaskNode rNode = (TaskNode) pd.getNode("r");
Set rNodeTasks = rNode.getTasks();
Task rtTask = new Task("RuntimeTask");
rtTask.setSignalling(true);
rtTask.setBlocking(true);
rNodeTasks.add(rtTask);
rootToken.signal();
System.out.println("currentNode: " + rootToken.getNode().getName());
Node node = rootToken.getNode();
if(node instanceof TaskNode){
Collection taskInstances = tmi.getTaskInstances();
Iterator iter = taskInstances.iterator();
while(iter.hasNext()){
TaskInstance ti = (TaskInstance) iter.next();
ti.start();
ti.setVariable(ti.getName() + "_LongVar", new Long("9999"));
ti.setVariable(ti.getName() + "_StringVar", "TaskInstanceStringValue");
Thread.currentThread().sleep(2000);
ti.end();
}
}
System.out.println("currentNode: " + rootToken.getNode().getName());
node = rootToken.getNode();
if(node instanceof TaskNode){
TaskNode tn = (TaskNode) node;
// fetch all task instances even those that are finished.
Collection taskInstances = tmi.getTaskInstances();
Iterator iter = taskInstances.iterator();
while(iter.hasNext()){
TaskInstance ti = (TaskInstance) iter.next();
if(ti.getStart() == null){
ti.start();
}
Thread.currentThread().sleep(2000);
if(ti.getEnd() == null){
ti.end();
}
}
}
// persist
jbpmContext.save(pi);
} catch (Exception e){
e.printStackTrace();
fail();
} finally {
try{
jbpmContext.close();
} catch (Exception e){
e.printStackTrace();
fail();
}
}
}
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4170623#4170623
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4170623
