2:25 p.m.
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#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...