12:39 p.m.
Swaminathan Bhaskar [https://community.jboss.org/people/swaminathan.bhaskar] created the
discussion
"Work Item not persisted"
To view the discussion, visit: https://community.jboss.org/message/760675#760675
--------------------------------------------------------------
Hello all;
I am using JPA persistence with jBPM 5.3 with MySQL database. I created a new domain
specific task and a corresponding work item handler and expect the work item to be
persisted along with the session info as well as process instance info when I kill the
process at the point shown in red below ... but do not see that happening. Any ideas or
thoughts
Here is the code for the work item handler
public class CustomWorkItemHandler implements WorkItemHandler {
@Override
public void executeWorkItem(WorkItem item, WorkItemManager manager) {
System.out.printf("\n-----> Waiting in custom work item %s <ID:%d>
for 60 secs\n", item.getName(), item.getId());
// Expect an entry in the DB for this work item when I kill the process
// Artificial wait
try {
Thread.sleep(60000);
}
catch (Exception ex) {
}
System.out.printf("\n-----> Completing custom work item %s
<ID:%d>\n", item.getName(), item.getId());
manager.completeWorkItem(item.getId(), null);
}
@Override
public void abortWorkItem(WorkItem item, WorkItemManager manager) {
}
}
Here is the main process code:
public class sample07 {
public static final String BPMN_RESOURCE = "sample07.bpmn";
public static final String BPM_PROCESS = "sample07";
public static final String WORK_ITEM_NAME = "custom_work_item";
public static final void main(String[] args) {
if (args.length != 2) {
System.out.printf("Usage: java %s <session-id>
<process-id>\n", sample07.class.getName());
System.exit(1);
}
try {
int sessionId = Integer.parseInt(args[0]);
long processId = Long.parseLong(args[1]);
// Setup Datasource
PoolingDataSource mysqlDS = new PoolingDataSource();
mysqlDS.setUniqueName("jdbc/MySQL-DS");
mysqlDS.setClassName("com.mysql.jdbc.jdbc2.optional.MysqlXADataSource");
mysqlDS.setMaxPoolSize(3);
mysqlDS.setAllowLocalTransactions(true);
mysqlDS.getDriverProperties().put("user", "mydbuser");
mysqlDS.getDriverProperties().put("password",
"mydbpass");
mysqlDS.getDriverProperties().put("url",
"jdbc:mysql://localhost:3306/mytestdb");
mysqlDS.init();
// Setup JPA persistence
EntityManagerFactory emf =
Persistence.createEntityManagerFactory("org.jbpm.persistence.jpa");
Environment env = KnowledgeBaseFactory.newEnvironment();
env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);
env.set(EnvironmentName.TRANSACTION_MANAGER,
TransactionManagerServices.getTransactionManager());
// Load and setup the BPM process
KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add(ResourceFactory.newClassPathResource(BPMN_RESOURCE),
ResourceType.BPMN2);
// Do we have any errors ?
if (kbuilder.hasErrors()) {
if (kbuilder.getErrors().size() > 0) {
for (KnowledgeBuilderError error : kbuilder.getErrors()) {
System.out.printf("Error building KnowledgeBase: %s\n",
error.getMessage());
}
}
throw new RuntimeException("Error building KnowledgeBase");
}
KnowledgeBase kbase = kbuilder.newKnowledgeBase();
StatefulKnowledgeSession ksession = null;
if (sessionId > 0) {
ksession = JPAKnowledgeService.loadStatefulKnowledgeSession(sessionId,
kbase, null, env);
JPAWorkingMemoryDbLogger logger = new JPAWorkingMemoryDbLogger(ksession);
// Register the custom work item handler
ksession.getWorkItemManager().registerWorkItemHandler(WORK_ITEM_NAME, new
CustomWorkItemHandler());
ProcessInstance processInstance = ksession.getProcessInstance(processId);
// Did the process instance complete successfully ?
if (processInstance.getState() == ProcessInstance.STATE_COMPLETED) {
System.out.printf("\n-----> Restarted business process [%s]
successfully completed\n", processInstance.getProcessId());
}
logger.dispose();
}
else {
ksession = JPAKnowledgeService.newStatefulKnowledgeSession(kbase, null,
env);
JPAWorkingMemoryDbLogger logger = new JPAWorkingMemoryDbLogger(ksession);
// Register the custom work item handler
ksession.getWorkItemManager().registerWorkItemHandler(WORK_ITEM_NAME, new
CustomWorkItemHandler());
System.out.printf("\n-----> Session ID: %d\n",
ksession.getId());
// Create the process instance
ProcessInstance processInstance =
ksession.createProcessInstance(BPM_PROCESS, null);
System.out.printf("\n-----> Starting new Business process %s
<ID:%d>\n", processInstance.getProcessId(), processInstance.getId());
// Start the BPM process
ksession.startProcessInstance(processInstance.getId());
// Did the process instance complete successfully ?
if (processInstance.getState() == ProcessInstance.STATE_COMPLETED) {
System.out.printf("\n-----> Business process %s <ID:%d>
successfully completed\n", processInstance.getProcessId(), processInstance.getId());
}
logger.dispose();
}
}
catch (Exception ex) {
ex.printStackTrace(System.err);
System.exit(1);
}
System.exit(0);
}
}
And here is the persistence.xml:
<persistence version="1.0"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd
http://java.sun.com/xml/ns/persistence/orm
http://java.sun.com/xml/ns/persistence/orm_1_0.xsd"
xmlns:orm="http://java.sun.com/xml/ns/persistence/orm"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://java.sun.com/xml/ns/persistence">
<persistence-unit name="org.jbpm.persistence.jpa"
transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>jdbc/MySQL-DS</jta-data-source>
<mapping-file>META-INF/JBPMorm.xml</mapping-file>
<mapping-file>META-INF/ProcessInstanceInfo.hbm.xml</mapping-file>
<!-- Process Related -->
<class>org.drools.persistence.info.SessionInfo</class>
<class>org.drools.persistence.info.WorkItemInfo</class>
<class>org.jbpm.persistence.processinstance.ProcessInstanceInfo</class>
<class>org.jbpm.process.audit.ProcessInstanceLog</class>
<class>org.jbpm.process.audit.NodeInstanceLog</class>
<class>org.jbpm.process.audit.VariableInstanceLog</class>
<properties>
<property name="hibernate.dialect"
value="org.hibernate.dialect.MySQL5Dialect" />
<property name="hibernate.connection.autocommit"
value="false" />
<property name="hibernate.max_fetch_depth"
value="3"/>
<property name="hibernate.hbm2ddl.auto" value="update"
/>
<property name="hibernate.show_sql" value="true"
/>
<property name="hibernate.transaction.manager_lookup_class"
value="org.hibernate.transaction.BTMTransactionManagerLookup" />
</properties>
</persistence-unit>
</persistence>
Any help appreciated.
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/760675#760675]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&...]