<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html>
<body link="#355491" alink="#4262a1" vlink="#355491" style="background: #e2e2e2; margin: 0; padding: 20px;">
<div>
<table cellpadding="0" bgcolor="#FFFFFF" border="0" cellspacing="0" style="border: 1px solid #dadada; margin-bottom: 30px; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td>
<table border="0" cellpadding="0" cellspacing="0" bgcolor="#FFFFFF" style="border: solid 2px #ccc; background: #dadada; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td bgcolor="#000000" valign="middle" height="58px" style="border-bottom: 1px solid #ccc; padding: 20px; -moz-border-radius-topleft: 3px; -moz-border-radius-topright: 3px; -webkit-border-top-right-radius: 5px; -webkit-border-top-left-radius: 5px;">
<h1 style="color: #333333; font: bold 22px Arial, Helvetica, sans-serif; margin: 0; display: block !important;">
<!-- To have a header image/logo replace the name below with your img tag -->
<!-- Email clients will render the images when the message is read so any image -->
<!-- must be made available on a public server, so that all recipients can load the image. -->
<a href="https://community.jboss.org/index.jspa" style="text-decoration: none; color: #E1E1E1">JBoss Community</a></h1>
</td>
</tr>
<tr>
<td bgcolor="#FFFFFF" style="font: normal 12px Arial, Helvetica, sans-serif; color:#333333; padding: 20px; -moz-border-radius-bottomleft: 4px; -moz-border-radius-bottomright: 4px; -webkit-border-bottom-right-radius: 5px; -webkit-border-bottom-left-radius: 5px;"><h3 style="margin: 10px 0 5px; font-size: 17px; font-weight: normal;">
Re: New process instance created but no task insert in db
</h3>
<span style="margin-bottom: 10px;">
created by <a href="https://community.jboss.org/people/joploya">Sandra Renaud</a> in <i>jBPM</i> - <a href="https://community.jboss.org/message/824694#824694">View the full discussion</a>
</span>
<hr style="margin: 20px 0; border: none; background-color: #dadada; height: 1px;">
<div class="jive-rendered-content"><p>Hello Demian,</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Thank you for your answer. Sur I will give my code. I use the localTaskService.</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>This is the producer for knowledgeSession :</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><pre class="jive-pre"><code class="jive-code jive-java">@Stateless
@LocalBean
<font color="navy"><b>public</b></font> <font color="navy"><b>class</b></font> KnowledgeSessionProducer <font color="navy"><b>implements</b></font> Serializable<font color="navy">{</font>
 
 
          <font color="navy"><b>private</b></font> <font color="navy"><b>static</b></font> <font color="navy"><b>final</b></font> <font color="navy"><b>long</b></font> serialVersionUID = -4494168896880405667L;
          <font color="navy"><b>private</b></font> Logger log = LoggerFactory.getLogger(KnowledgeSessionProducer.class);
          <font color="navy"><b>private</b></font> KnowledgeRuntimeLogger logger;
          <font color="navy"><b>private</b></font> StatefulKnowledgeSession ksession;
 
    @PersistenceUnit(unitName = <font color="red">"org.jbpm.task"</font>)
    <font color="navy"><b>private</b></font> EntityManagerFactory emf;
    <font color="navy"><b>private</b></font> @Inject RecoveryDao recoveryDao;
 
    <font color="navy"><b>public</b></font> @PostConstruct <font color="navy"><b>void</b></font> init()<font color="navy">{</font>
              log.debug(<font color="red">"init of KnowledgeSessionProducer ..."</font>);
   
              <font color="darkgreen">// By Setting the jbpm.usergroup.callback property with the call</font>
        <font color="darkgreen">// back class full name, task service will use this to validate the</font>
        <font color="darkgreen">// user/group exists and its permissions are ok.</font>
              InputStream usergroupsin = KnowledgeSessionProducer.class.getResourceAsStream(  <font color="red">"/jbpm.usergroup.callback.properties"</font> );
              <font color="navy"><b>if</b></font>(usergroupsin != <font color="navy"><b>null</b></font>) <font color="navy">{</font>
                        Properties callbackproperties = <font color="navy"><b>new</b></font> Properties();
                        <font color="navy"><b>try</b></font> <font color="navy">{</font>
                                  callbackproperties.load(usergroupsin);
                                  UserGroupCallbackManager.getInstance().setCallbackFromProperties(callbackproperties);
                                  log.debug(<font color="red">"Task service registered usergroup callback ..."</font>);
                        <font color="navy">}</font> <font color="navy"><b>catch</b></font> (Exception e) <font color="navy">{</font>
                                  log.debug(<font color="red">"Task service unable to register usergroup callback ..."</font>);
                        <font color="navy">}</font>
              <font color="navy">}</font>
   
              <font color="navy"><b>if</b></font>(UserGroupCallbackManager.getInstance().existsCallback())<font color="navy">{</font>
                        System.out.println(<font color="red">"userGroupCallBack exists ! :)"</font>);
              <font color="navy">}</font><font color="navy"><b>else</b></font><font color="navy">{</font>
                        System.out.println(<font color="red">"userGroupCallBack don't exist ! :("</font>);
              <font color="navy">}</font>
   
              TaskService taskService = <font color="navy"><b>new</b></font> TaskService(emf, SystemEventListenerFactory.getSystemEventListener());
   
              taskService.setUserinfo(<font color="navy"><b>new</b></font> AMSUserInfoImpl());
   
        TaskServiceSession taskSession = taskService.createSession();
        <font color="darkgreen">// Add users</font>
        @SuppressWarnings(<font color="red">"rawtypes"</font>)
                    Map vars = <font color="navy"><b>new</b></font> HashMap();
        InputStream usersin = KnowledgeSessionProducer.class.getResourceAsStream( <font color="red">"/LoadUsers.mvel"</font> );
        <font color="navy"><b>if</b></font>(usersin != <font color="navy"><b>null</b></font>) <font color="navy">{</font>
                  Reader reader = <font color="navy"><b>new</b></font> InputStreamReader( usersin );  
                  @SuppressWarnings(<font color="red">"unchecked"</font>)
                  Map<String, User> users = ( Map<String, User> ) TaskService.eval( reader, vars );  
                  log.debug(<font color="red">"Users to load in db : ..."</font>);
                  <font color="navy"><b>for</b></font> ( User user : users.values() ) <font color="navy">{</font>
                            taskSession.addUser( user );
                            log.debug(<font color="red">" - "</font>+user);
                  <font color="navy">}</font>          
        <font color="navy">}</font>
        InputStream groupsin = KnowledgeSessionProducer.class.getResourceAsStream( <font color="red">"/LoadGroups.mvel"</font> );
        <font color="navy"><b>if</b></font>(groupsin != <font color="navy"><b>null</b></font>) <font color="navy">{</font>
                  Reader reader = <font color="navy"><b>new</b></font> InputStreamReader( groupsin );  
                  @SuppressWarnings(<font color="red">"unchecked"</font>)
                  Map<String, Group> groups = ( Map<String, Group> ) TaskService.eval( reader, vars );    
                  log.debug(<font color="red">"Groups to load in db : ..."</font>);
                  <font color="navy"><b>for</b></font> ( Group group : groups.values() ) <font color="navy">{</font>
                            taskSession.addGroup( group );
                            log.debug(<font color="red">" - "</font>+group);
                  <font color="navy">}</font>
        <font color="navy">}</font>
       
        taskSession.dispose();
        log.debug(<font color="red">"Task service started correctly!"</font>);
        log.debug(<font color="red">"Task service running ..."</font>);
    <font color="navy">}</font>
   
          @Produces
          @ApplicationScoped
          <font color="navy"><b>public</b></font> StatefulKnowledgeSession produceKnowledgeSession()<font color="navy">{</font>
                    log.debug(<font color="red">"produce the KnowledgeSession ..."</font>);
                    <font color="darkgreen">//Create the knowledgeBase</font>
                    <font color="darkgreen">/*This factory is used to build the knowledge base resources that are held collectively in KnowledgePackages.*/</font>
                    KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
 
                    <font color="darkgreen">//Add all processes to the knowledgeBuilder</font>
                    List<Resource> resources = getProcessDefinitionList();
                    <font color="navy"><b>for</b></font> (Resource resource : resources) <font color="navy">{</font>
                              kbuilder.add(resource, ResourceType.BPMN2);
                    <font color="navy">}</font>
 
                    <font color="darkgreen">/*Create a new KnowledgeBase from the knowledge packages that have been added to this builder.
                     * An exception is thrown if there are any errors.*/</font>
<font color="darkgreen">//                    assertFalse( kbuilder.hasErrors() );</font>
                    <font color="navy"><b>if</b></font> ( kbuilder.hasErrors() ) <font color="navy">{</font>
                         log.error( kbuilder.getErrors().toString() );
                     <font color="navy">}</font>
                    KnowledgeBase kbase = kbuilder.newKnowledgeBase();
 
                    Environment env = KnowledgeBaseFactory.newEnvironment();
                    env.set( EnvironmentName.ENTITY_MANAGER_FACTORY, emf );
 
                    <font color="navy"><b>if</b></font>(kbase != <font color="navy"><b>null</b></font>)<font color="navy">{</font>
                              System.out.println(<font color="red">"knowledge base NOT null"</font>);
                              <font color="navy"><b>for</b></font>(org.drools.definition.process.Process p :kbase.getProcesses())<font color="navy">{</font>
                                        System.out.println(<font color="red">" - process "</font>+p.getName()+<font color="red">" ["</font>+p.getId()+<font color="red">"]"</font>);
                              <font color="navy">}</font>
 
 
                    <font color="navy">}</font>
 
                    <font color="darkgreen">//TODO</font>
                    <font color="darkgreen">/*
                     * recover a persistent knowledge session or instanciate a new one
                     */</font>
                    <font color="navy"><b>int</b></font> sessionId = recoveryDao.getPersistentKnowledgeSession();
 
 
                    <font color="navy"><b>if</b></font>(sessionId < 0)<font color="navy">{</font>
                              ksession = JPAKnowledgeService.newStatefulKnowledgeSession(kbase, null, env);
                              KnowledgeSessionRecovery kSessionRecovery = <font color="navy"><b>new</b></font> KnowledgeSessionRecovery(ksession.getId());
                              recoveryDao.savePersistentKnowledgeSession(kSessionRecovery);
                    <font color="navy">}</font><font color="navy"><b>else</b></font><font color="navy">{</font>
                              ksession = JPAKnowledgeService.loadStatefulKnowledgeSession(sessionId, kbase, null, env);
                    <font color="navy">}</font>
 
 
 
                    <font color="darkgreen">/*Create a new StatefulKnowledgeSession using the default session configuration.
                     * Don't forget to dispose() session when you are done.
                     * Long term out of the box persistence of runtime state with JPA is possible with Drools & jBPM.
                     *
                     * StatefulKnowledgeSession is the most common way to interact with the engine.
                     * A StatefulKnowledgeSession allows the application to establish an iterative conversation with the engine,
                     * where the state of the session is kept across invocations.*/</font>
<font color="darkgreen">//                    StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();</font>
                    System.out.println(<font color="red">" !!!! DEBUG SESSION PERSISTENCE : new session with id : "</font>+ksession.getId()+<font color="red">" !!!!"</font>);
 
        logger = KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, <font color="red">"loggerFile"</font>, 1000);
        KnowledgeRuntimeLoggerFactory.newConsoleLogger(ksession);
       
       
       
        <font color="darkgreen">/*A work item manager is responsible for finding the right work item handler when a work item should be executed
         * and should be notified when this work item has been completed (or aborted).
         *
         * Register the given handler for all work items of the given type of work
         * This part is done in the LocalHumanTaskService*/</font>
        WorkItemHandler wihHT = <font color="navy"><b>new</b></font> HumanTaskHandler();
        ksession.getWorkItemManager().registerWorkItemHandler(<font color="red">"Human Task"</font>, wihHT );
       
<font color="darkgreen">//        ksession.getEnvironment().set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);</font>
       
        <font color="darkgreen">/*
         * Register WorkItem Handler for Email
         */</font>
<font color="darkgreen">//        EmailWorkItemHandler emailHandler =  new EmailWorkItemHandler();</font>
<font color="darkgreen">//        ksession.getWorkItemManager().registerWorkItemHandler("Email", emailHandler);</font>
       
        <font color="navy"><b>return</b></font> ksession;
          <font color="navy">}</font>
 
          <font color="navy"><b>public</b></font> KnowledgeRuntimeLogger getLogger()<font color="navy">{</font>
                    <font color="navy"><b>return</b></font> this.logger;
          <font color="navy">}</font>
 
          @PreDestroy
          <font color="navy"><b>public</b></font> <font color="navy"><b>void</b></font> end()<font color="navy">{</font>
                    ksession.dispose();
                    log.debug(<font color="red">"ksession disposed"</font>);
          <font color="navy">}</font>
 
 
          <font color="navy"><b>private</b></font> List<Resource> getProcessDefinitionList()<font color="navy">{</font>
                    List<Resource> resourceList = <font color="navy"><b>new</b></font> ArrayList<>();
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.datacorrections.bpmn2"</font>));
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.newfinishedgood.bpmn2"</font>));
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.newproductline.bpmn2"</font>));
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.nfep.bpmn2"</font>));
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.newcpbeforem29commontrunk.bpmn2"</font>));
                    resourceList.add(ResourceFactory.newClassPathResource(<font color="red">"workflows/com.st.ams.flows.newcpbeforem29.bpmn2"</font>));
 
                    <font color="darkgreen">/**
                     * TODO
                     * add all other process here
                     */</font>
                    <font color="navy"><b>return</b></font> resourceList;
          <font color="navy">}</font>
<font color="navy">}</font>
 
</code></pre><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>and here the method in a class where I put all functions to interact with the engine :</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><pre class="jive-pre"><code class="jive-code jive-java"><font color="darkgreen">/**
           * Start a new processInstance of an existing Process
           * and set the variables of this instance
           * @param processId, map of variables
           * @return ProcessInstance created
           */</font>
          <font color="navy"><b>public</b></font> ProcessInstance startProcess(String processId, Map<String, Object> parameters)<font color="navy">{</font>
                    ProcessInstance p = kSession.startProcess(processId,parameters);
                    <font color="navy"><b>return</b></font> p;
          <font color="navy">}</font>
 
          <font color="darkgreen">/**
           * Return the WorkflowProcessInstance associated to a Task
           * This instance allow to access the map of variables
           * @return WorkflowProcessInstance managed
           */</font>
          <font color="navy"><b>public</b></font> WorkflowProcessInstance getWorkflowProcessInstance(<font color="navy"><b>long</b></font> processInstanceId)<font color="navy">{</font>
                    <font color="navy"><b>return</b></font> (WorkflowProcessInstance)kSession.getProcessInstance(processInstanceId);
          <font color="navy">}</font>
 
          <font color="darkgreen">/**
           * This method allow to access object store in
           * process instance variables
           * @return an object link to the processInstance
           */</font>
          <font color="navy"><b>public</b></font> Object getProcessVariable(<font color="navy"><b>final</b></font> Long processInstanceId, Long taskId, String key)<font color="navy">{</font>
                    Object retObj = <font color="navy"><b>null</b></font>;
 
                    WorkflowProcessInstance wpi = (WorkflowProcessInstance)kSession.getProcessInstance(processInstanceId);
                    <font color="navy"><b>if</b></font>((wpi == <font color="navy"><b>null</b></font>) || (wpi.getVariable(key) == <font color="navy"><b>null</b></font>))<font color="navy">{</font>
                              System.out.println(<font color="red">"workflow process instance is null :-("</font>);
                              Map<String, Object> variables = kSession.execute(<font color="navy"><b>new</b></font> GenericCommand<Map<String, Object>>() <font color="navy">{</font>
 
 
                                  <font color="navy"><b>public</b></font> Map<String, Object> execute(Context context) <font color="navy">{</font>
                                      StatefulKnowledgeSession ksession = ((KnowledgeCommandContext) context).getStatefulKnowledgesession();
                                      org.jbpm.process.instance.ProcessInstance processInstance = (org.jbpm.process.instance.ProcessInstance) ksession.getProcessInstance(processInstanceId);
                                      VariableScopeInstance variableScope = (VariableScopeInstance) processInstance.getContextInstance(VariableScope.VARIABLE_SCOPE);
                                      Map<String, Object> variables = variableScope.getVariables();
                                      <font color="navy"><b>return</b></font> variables;
                                  <font color="navy">}</font>
 
 
                              <font color="navy">}</font>);
                              System.out.println(<font color="red">"variables size : "</font>+variables.size());
                              <font color="navy"><b>for</b></font>(String str : variables.keySet())<font color="navy">{</font>
                                        System.out.println(<font color="red">" - "</font>+str);
                              <font color="navy">}</font>
                              retObj = variables.get(key);
                    <font color="navy">}</font><font color="navy"><b>else</b></font><font color="navy">{</font>
                              System.out.println(<font color="red">"workflow process instance is NOT null :-)"</font>);
                              retObj = wpi.getVariable(key);
                    <font color="navy">}</font>
                    <font color="navy"><b>if</b></font>(retObj == <font color="navy"><b>null</b></font>)<font color="navy">{</font>
                              System.out.println(<font color="red">" get variable return null ::-("</font>);
                    <font color="navy">}</font><font color="navy"><b>else</b></font><font color="navy">{</font>
                              System.out.println(<font color="red">" get variable return "</font>+retObj.toString()+<font color="red">"  |-)"</font>);
                    <font color="navy">}</font>
                    <font color="navy"><b>return</b></font> retObj;
          <font color="navy">}</font>
 
</code></pre><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Thanks again.</p></div>
<div style="background-color: #f4f4f4; padding: 10px; margin-top: 20px;">
<p style="margin: 0;">Reply to this message by <a href="https://community.jboss.org/message/824694#824694">going to Community</a></p>
<p style="margin: 0;">Start a new discussion in jBPM at <a href="https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2034">Community</a></p>
</div></td>
</tr>
</tbody>
</table>
</td>
</tr>
</tbody>
</table>
</div>
</body>
</html>