0 Replies Latest reply on Jun 4, 2008 3:02 AM by null null

    Even though the task is not for that actor i get that task u

    null null Newbie

      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>




      AssignTask.java
      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);
       }
      
      }


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


      Test.java
      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();
       }
       }
      
      }
      


      part of Sysout output
      a1 1
      b1 1
      c1 1
      a1 task2
      c2 task2
      a1 1
      b1 0
      c1 0