Below is the code for the experiment
I have assigned the process to pool of actors
After that task there is another task which is assigned to a single actor
on reaching that task Node I try to get the remaining tasks for c but when i try the following code
System.out.println("c1 "+ taskMgmtSession.findPooledTaskInstances("c").size());

it gives output as 1 and it reaches stage task2 even though through the assignment of task 2 its only applicable to actor "a".

System.out.println("c2 "+ ((TaskInstance)taskMgmtSession.findPooledTaskInstances("c").get(0)).getToken().getNode().getName());

gives output as task2

Thanks in advance

CSJakharia


processdefinition.xml

<?xml version="1.0" encoding="UTF-8"?>

<process-definition xmlns="urn:jbpm.org:jpdl-3.2" name="authoring">
 <start-state name="start-state1">
 <task>
 </task>
 <transition to="task1"></transition>
 </start-state>


 <task-node name="task1">
 <description>
 task1
 </description>
 <task>
 <assignment class="com.workflow.AssignTask"></assignment>
 </task>
 <transition to="task2"></transition>
 </task-node>

 <task-node name="task2">
 <description>
 task2
 </description>
 <task>
 <assignment class="com.workflow.AssignTask1"></assignment>
 </task>
 <transition to="end"></transition>
 </task-node>

 <node name="end">
 <action class="com.workflow.HandleAction"> </action>
 <transition to="end-state1"></transition>
 </node>


 <end-state name="end-state1">

 </end-state>


</process-definition>

public class AssignTask implements AssignmentHandler {

 public void assign(Assignable assignable, ExecutionContext executionContext)
 throws Exception {
 // TODO Auto-generated method stub
 String actors[]=new String[]{"a","b","c"};
 assignable.setPooledActors(actors);
 }

}

public class AssignTask1 implements AssignmentHandler {

 public void assign(Assignable assignable, ExecutionContext executionContext)
 throws Exception {
 // TODO Auto-generated method stub
 assignable.setActorId("a");
 }

}

public class Test {
 static JbpmConfiguration jbpmConfiguration = null;

 public static void deployProcessDefinition()
 {
 try {
 ProcessDefinition processDefinition = ProcessDefinition.parseXmlInputStream(new FileInputStream("D:\\WorkFlowAuthoringPOC\\src\\main\\jpdl\\a\\processdefinition.xml"));
 JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
 jbpmContext.deployProcessDefinition(processDefinition);
 jbpmContext.close();
 } catch (FileNotFoundException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
 }
 }
 public static void main(String[] args) {
 try {
 jbpmConfiguration = JbpmConfiguration.parseInputStream(new FileInputStream("D:\\Cobra\\workspace\\WorkFlowAuthoringPOC\\src\\main\\config\\jbpm.cfg.xml"));
 jbpmConfiguration.createSchema();
 deployProcessDefinition();
 JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
 System.out.println("jbpmContext.getActorId() "+jbpmContext.getActorId());
 GraphSession graphSession = jbpmContext.getGraphSession();
 ProcessDefinition processDefinition =
 graphSession.findLatestProcessDefinition("authoring");
 ProcessInstance processInstance = new ProcessInstance(processDefinition);
 Token token=processInstance.getRootToken();
 // Let's start the process execution, leaving the start-state
 // over its default transition.
 token.signal();
 TaskInstance taskInstance = (TaskInstance)
 processInstance
 .getTaskMgmtInstance()
 .getTaskInstances()
 .iterator().next();

 System.out.println("size "+processInstance.getTaskMgmtInstance().getTaskInstances().size());
 System.out.println("taskInstance.getActorId() " +taskInstance.getActorId());
 System.out.println("taskInstance.getPooledActors() " +taskInstance.getPooledActors());
 TaskMgmtSession taskMgmtSession= jbpmContext.getTaskMgmtSession();
 System.out.println(taskMgmtSession.findPooledTaskInstances("a").size());
 System.out.println(taskMgmtSession.findPooledTaskInstances("b").size());
 ((TaskInstance)taskMgmtSession.findPooledTaskInstances("a").get(0)).getToken().signal();

 System.out.println("a1 "+ taskMgmtSession.findPooledTaskInstances("a").size());
 System.out.println("b1 "+ taskMgmtSession.findPooledTaskInstances("b").size());
 System.out.println("c1 "+ taskMgmtSession.findPooledTaskInstances("c").size());
 System.out.println("a1 "+ ((TaskInstance)taskMgmtSession.findPooledTaskInstances("a").get(0)).getToken().getNode().getName());
 System.out.println("c2 "+ ((TaskInstance)taskMgmtSession.findPooledTaskInstances("c").get(0)).getToken().getNode().getName());
 System.out.println("a1 "+ taskMgmtSession.findTaskInstances("a").size());
 System.out.println("b1 "+ taskMgmtSession.findTaskInstances("b").size());
 System.out.println("c1 "+ taskMgmtSession.findTaskInstances("c").size());


 } catch (FileNotFoundException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
 }
 }

}