[JBoss jBPM] - jumping to a new task node
by akriel
For various reasons within my app that is using JBPM I need to be able to abort all current tasks and jump to a different location in the process under certain circumstances (specifically if at any time the underlying data is updated). I have written a tag to do this though it isn't quite working the way I expected.
The code will create the task I specify, but it sometimes create two of them, and sometimes will also create an additional task form my startnode. I know I must be missing something but I can't see what.
Any help is greatly appreciated.
| public class RestartToNodeActionListener implements JbpmActionListener
| {
| private final ValueExpression processInstanceExpression;
| private final ValueExpression toNodeExpression;
|
| public RestartToNodeActionListener( final ValueExpression processInstance, final ValueExpression toNode )
| {
| processInstanceExpression = processInstance;
| toNodeExpression = toNode;
| }
|
| public String getName()
| {
| return "restartToNodeActionListener";
| }
|
| public void handleAction( JbpmJsfContext context, ActionEvent event )
| {
| try
| {
| final FacesContext facesContext = FacesContext.getCurrentInstance();
| final ELContext elContext = facesContext.getELContext();
| ProcessInstance processInstance = ( ProcessInstance ) processInstanceExpression.getValue( elContext );
| String toNodeName = ( String ) toNodeExpression.getValue( elContext );
|
| // get the task manager
| TaskMgmtInstance taskManager = processInstance.getTaskMgmtInstance();
|
| // get the old root token
| Token oldRoot = processInstance.getRootToken();
|
| // get the def so we can find the start node
| ProcessDefinition processDefinition = processInstance.getProcessDefinition();
|
| // get the start node to create the new root token
| Node startNode = processDefinition.getStartState();
|
| // get all tasks for the current instance
| List<TaskInstance> tasks = new ArrayList<TaskInstance>( taskManager.getTaskInstances() );
|
| int taskCount = tasks.size();
| for ( int i = 0; i < taskCount; i++ )
| {
| TaskInstance taskInstance = tasks.get( i );
|
| if ( taskInstance != null )
| {
| // remove each task instance
| taskManager.removeTaskInstance( taskInstance );
|
| // if the task is active cancel it
| if ( taskInstance.isOpen() && !taskInstance.isCancelled() )
| {
| // try to cancel the task instance
| taskInstance.cancel();
| }
| }
| }
|
| // added this because not all tasks were being canceled and was hoping it would be a catch all.
| taskManager.endAll();
|
| // get the task definition manager
| TaskMgmtDefinition taskManagerDefinition = taskManager.getTaskMgmtDefinition();
|
| // set the node we want to jump to
| Task startTask = taskManagerDefinition.getTask( toNodeName );
|
| // get the node to move the root token to
| Node startingNode = taskManagerDefinition.getProcessDefinition().getNode( toNodeName );
|
| // set the root token to point to the node
| oldRoot.setNode( startingNode );
|
| // create the new task instance
| TaskInstance newStartInstance = taskManager.createTaskInstance( startTask, oldRoot );
|
| // add in a start task
| taskManager.addTaskInstance( newStartInstance );
|
|
| context.selectOutcome("success");
| }
| catch ( Exception ex )
| {
| context.setError( "Error clearing tasks and resetting to task", ex );
| return;
| }
| }
|
| }
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4226278#4226278
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4226278
16 years, 11 months