<!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="http://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: How to continue process in a web application
</h3>
<span style="margin-bottom: 10px;">
created by <a href="http://community.jboss.org/people/johnesky">Jo Blithe</a> in <i>jBPM</i> - <a href="http://community.jboss.org/message/617433#617433">View the full discussion</a>
</span>
<hr style="margin: 20px 0; border: none; background-color: #dadada; height: 1px;">
<div class="jive-rendered-content"><p>Thanks Demain for your reply. Here are some of my condfiguration files...</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Persistence.xml</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p><?xml version="1.0" encoding="UTF-8"?></p><p><span><persistence version="1.0" xmlns="</span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence" target="_blank">http://java.sun.com/xml/ns/persistence</a><span>" xmlns:orm="</span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence/orm" target="_blank">http://java.sun.com/xml/ns/persistence/orm</a><span>" xmlns:xsi="</span><a class="jive-link-external-small" href="http://www.w3.org/2001/XMLSchema-instance" target="_blank">http://www.w3.org/2001/XMLSchema-instance</a><span>" xsi:schemaLocation="</span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence" target="_blank">http://java.sun.com/xml/ns/persistence</a><span>       </span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd" target="_blank">http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd</a><span>    </span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence/orm" target="_blank">http://java.sun.com/xml/ns/persistence/orm</a><span>     </span><a class="jive-link-external-small" href="http://java.sun.com/xml/ns/persistence/orm_1_0.xsd" target="_blank">http://java.sun.com/xml/ns/persistence/orm_1_0.xsd</a><span>"></span></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>    <persistence-unit name="org.jbpm.persistence.jpa" transaction-type="JTA"></p><p>        <provider>org.hibernate.ejb.HibernatePersistence</provider></p><p>        <jta-data-source>java:comp/env/jdbc/testDS1</jta-data-source></p><p>       </p><p>        <class>org.jbpm.persistence.processinstance.ProcessInstanceInfo</class></p><p>        <class>org.jbpm.persistence.processinstance.ProcessInstanceEventInfo</class>    </p><p>        <class>org.drools.persistence.info.SessionInfo</class></p><p>        <class>org.drools.persistence.info.WorkItemInfo</class></p><p>        <class>org.jbpm.process.audit.ProcessInstanceLog</class></p><p>        <class>org.jbpm.process.audit.NodeInstanceLog</class></p><p>        <class>org.jbpm.process.audit.VariableInstanceLog</class></p><p>        <properties></p><p>                  </p><p>                  <!-- CONFIGURATION TO USE H2 --></p><p>          <property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/> </p><p>                              <!-- COMMON CONFIGURATION --></p><p>            <property name="hibernate.max_fetch_depth" value="3"/></p><p>            <property name="hibernate.hbm2ddl.auto" value="create-drop" /></p><p>            <property name="hibernate.show_sql" value="true" /></p><p>            <property name="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.BTMTransactionManagerLookup" /></p><p>            </p><p>         </properties> </p><p>                      </p><p>    </persistence-unit></p><p></persistence></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>index.jsp</p><p>        <%</p><p>      </p><p>                PoolingDataSource ds1 = new PoolingDataSource();</p><p>                    ds1.setUniqueName("jdbc/testDS1");</p><p>                    ds1.setClassName("org.postgresql.xa.PGXADataSource");</p><p>                    ds1.setMaxPoolSize(3);</p><p>                    ds1.setAllowLocalTransactions(true);</p><p>                    ds1.getDriverProperties().put("serverName", "localhost");</p><p>                    ds1.getDriverProperties().put("user", "postgres");</p><p>                    ds1.getDriverProperties().put("password", "postgres");</p><p>                    ds1.getDriverProperties().put("databaseName", "jbpm5");</p><p>                    ds1.init();</p><p>  </p><p>                readKnowledge redaccion = new readKnowledge();</p><p>                    KnowledgeBase kbase = redaccion.readKnowledgeBase();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                 EntityManagerFactory emf1 = Persistence</p><p>                    .createEntityManagerFactory("org.jbpm.persistence.jpa");</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Environment env = KnowledgeBaseFactory.newEnvironment();</p><p>env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf1);</p><p>env.set(EnvironmentName.TRANSACTION_MANAGER,</p><p>                    TransactionManagerServices.getTransactionManager());</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p> EntityManagerFactory emf = Persistence.createEntityManagerFactory("org.jbpm.task");</p><p>                     </p><p>                      SystemEventListener systemEventListener = SystemEventListenerFactory.getSystemEventListener();</p><p>                     </p><p>                      TaskService taskService = new TaskService(emf, systemEventListener);</p><p>                     </p><p>                      TaskServiceSession taskSession = taskService.createSession();</p><p>                     </p><p>                      taskSession.addUser(new User("Administrator"));</p><p>                      taskSession.addUser(new User("mina"));</p><p>                      </p><p>                     </p><p>                      MinaTaskServer server = new MinaTaskServer( taskService );</p><p>                      Thread thread = new Thread( server );</p><p>                      thread.start();</p><p>  </p><p>                       </p><p>                      StatefulKnowledgeSession ksession = JPAKnowledgeService.newStatefulKnowledgeSession(kbase, null,</p><p>                                                  env);</p><p>                      new JPAWorkingMemoryDbLogger(ksession);</p><p>                      </p><p>                              KnowledgeRuntimeLoggerFactory.newConsoleLogger(ksession);</p><p>  </p><p>                              //Logger that will give information about the process state, variables, etc</p><p>                              JPAProcessInstanceDbLog processLog = new JPAProcessInstanceDbLog(ksession.getEnvironment());</p><p>  </p><p>  </p><p>                      ksession.getWorkItemManager().registerWorkItemHandler("Handler", new JavaHandlerWorkItemHandler(ksession));</p><p>  </p><p>                      ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new WSHumanTaskHandler());</p><p>                      </p><p>                      </p><p>                     //KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newFileLogger(ksession, "test");</p><p>                      // start a new process instance</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                              ProcessInstance process = ksession.createProcessInstance("com.sample.bpmn.hello",</p><p>                                                  null);</p><p>                              ksession.insert(process);</p><p>                              long processInstanceId = process.getId();</p><p>                              ksession.startProcessInstance(processInstanceId);</p><p>                              Thread.sleep(2000);</p><p>  </p><p>                      //ksession.startProcess("com.sample.bpmn.hello");</p><p>                     </p><p>                    //   ksession.fireAllRules();</p><p>                     </p><p>                     // logger.close();</p><p>                      </p><p>                            TaskClient client = new TaskClient(new MinaTaskClientConnector("mina",</p><p>                                           new MinaTaskClientHandler(</p><p>                                             SystemEventListenerFactory.getSystemEventListener())));</p><p>  </p><p>                        try</p><p>                                                               {</p><p>                                          client.connect("127.0.0.1", 9123);</p><p>                                          BlockingTaskSummaryResponseHandler summaryHandler = new BlockingTaskSummaryResponseHandler();</p><p>                                          client.getTasksAssignedAsPotentialOwner("mina", "en-UK",</p><p>                                            summaryHandler);</p><p>                                          List <TaskSummary> tasks = summaryHandler.getResults();</p><p>                                          TaskSummary task = null;</p><p>                                          for (TaskSummary taskSummary : tasks) {</p><p>                                           System.out.println(taskSummary.getId() + " : "</p><p>                                             + taskSummary.getName());</p><p>                                           task = taskSummary;</p><p>                                          }</p><p>                                          if (task != null) {</p><p>                                                     BlockingTaskOperationResponseHandler operationHandler = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.release(task.getId(), "mina", operationHandler);</p><p>                                                     client.claim(task.getId(), "Administrator", operationHandler);</p><p>                                                     operationHandler.waitTillDone(10000);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                     operationHandler = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.start(task.getId(), "Administrator", operationHandler);</p><p>                                                     operationHandler.waitTillDone(10000);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                     operationHandler = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.complete(task.getId(), "Administrator", null, operationHandler);</p><p>                                                     operationHandler.waitTillDone(10000);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                    }</p><p>                                          </p><p>                                          Thread.sleep(1000);</p><p>                                           </p><p>                                          BlockingTaskSummaryResponseHandler summaryHandler2 = new BlockingTaskSummaryResponseHandler();</p><p>                                          client.getTasksAssignedAsPotentialOwner("mina", "en-UK",</p><p>                                            summaryHandler2);</p><p>                                          List <TaskSummary> tasks2 = summaryHandler2.getResults();</p><p>                                          TaskSummary task2 = null;</p><p>                                          for (TaskSummary taskSummary : tasks2) {</p><p>                                           System.out.println(taskSummary.getId() + " : "</p><p>                                             + taskSummary.getName());</p><p>                                           task2 = taskSummary;</p><p>                                          }</p><p>                                          if (task2 != null) {</p><p>                                                     BlockingTaskOperationResponseHandler operationHandler2 = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.release(task2.getId(), "mina", operationHandler2);</p><p>                                                     client.claim(task2.getId(), "Administrator", operationHandler2);</p><p>                                                     operationHandler2.waitTillDone(10000);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                     operationHandler2 = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.start(task2.getId(), "Administrator", operationHandler2);</p><p>                                                     operationHandler2.waitTillDone(10000);</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                     operationHandler2 = new BlockingTaskOperationResponseHandler();</p><p>                                                     client.complete(task2.getId(), "Administrator", null, operationHandler2);</p><p>                                                     operationHandler2.waitTillDone(10000);</p><p>                                          }</p><p>                              //now check in the logs the process finished.</p><p>                                  </p><p>                                  UserTransaction ut =</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>  (UserTransaction) new InitialContext().lookup( "java:comp/UserTransaction" );</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>ut.begin();</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                                                  ProcessInstanceLog processInstanceLog = processLog.findProcessInstance(processInstanceId);</p><p>                                                  processInstanceLog.getEnd();</p><p>  </p><p>                                        ut.commit();</p><p>                                        </p><p>                               </p><p>                                                  Thread.sleep(1000);</p><p>                                                  client.disconnect();</p><p>  </p><p>        </p><p>                                        </p><p>                                         }  catch (Exception e) {</p><p>                                                    e.printStackTrace();</p><p>                                         } finally {</p><p>                                          try {</p><p>                                           client.disconnect();</p><p>                                          } catch (Exception e) {</p><p>                                           e.printStackTrace();</p><p>                                          }</p><p>                                  System.exit(0);</p><p>                                                                   }</p><p>        %></p></div>
<div style="background-color: #f4f4f4; padding: 10px; margin-top: 20px;">
<p style="margin: 0;">Reply to this message by <a href="http://community.jboss.org/message/617433#617433">going to Community</a></p>
<p style="margin: 0;">Start a new discussion in jBPM at <a href="http://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>