Hi,
I'm developing a business process flow using jBPM, and so far I've created the BPMN and configured the persistence to work with my database. I've noticed a class mapping in the persistence.xml file for the tables SessionInfo, WorkItemInfo and ProcessInstanceInfo, and they are indeed successfully created in my MySQL schema. The problem is, once I start a new knowledge session and run my process instance, nothing is written in those tables, so I can't really restore sessions (not having persistence, then). What am I doing wrong here? Any help would be appreciated!
Here's my code so far:
.java main
// Load up the events knowledge base
KnowledgeBase eventKbase = readEventKnowledgeBase();
StatefulKnowledgeSession eventKsession = eventKbase
.newStatefulKnowledgeSession();
// Load up the knowledge base
KnowledgeBase kbase = readKnowledgeBase();
StatefulKnowledgeSession ksession = null;
// Settings up JPA persistence
EntityManagerFactory emf = Persistence
.createEntityManagerFactory("test");
Environment env = KnowledgeBaseFactory.newEnvironment();
env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);
env.set(EnvironmentName.TRANSACTION_MANAGER,
TransactionManagerServices.getTransactionManager());
// create a new knowledge session that uses JPA to store the runtime
// state
ksession = JPAKnowledgeService.newStatefulKnowledgeSession(kbase, null,
env);
// this session id - will have to be stored for recovery of session
int sessionId = ksession.getId();
System.out.printf("\n-----> Session ID: %d\n", sessionId);
// loads up the session with sessionId - not sure how to use this yet
// ksession =
// JPAKnowledgeService.loadStatefulKnowledgeSession(sessionId, kbase,
// null, env);
// uses custom process event listener
ksession.addEventListener(new CustomProcessEventListener(eventKsession));
// register work items
ksession.getWorkItemManager().registerWorkItemHandler("Notification",
new MyWorkItemHandler(ksession));
// start transaction
UserTransaction transaction = (UserTransaction) new InitialContext()
.lookup("java:comp/UserTransaction");
transaction.begin();
// Create the process instance
ProcessInstance processInstance = ksession.createProcessInstance(
"com.sample.bpmn.hello", null);
System.out.println("\n-----> Starting new Business process "
+ processInstance.getProcessId() + " <ID:" + sessionId + ">\n");
// Start the BPM process
ksession.startProcessInstance(processInstance.getId());
transaction.commit();
// Did the process instance complete successfully ?
if (processInstance.getState() == ProcessInstance.STATE_COMPLETED) {
System.out.printf("\n-----> Business process "
+ processInstance.getProcessId() + " <ID:" + sessionId
+ "> successfully completed\n");
}
// free resources and end session
emf.close();
ksession.dispose();
Custom Work Item Handler:
public class MyWorkItemHandler implements WorkItemHandler {
private KnowledgeRuntime session;
public MyWorkItemHandler() {
}
public MyWorkItemHandler(KnowledgeRuntime session) {
this();
this.session = session;
}
public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {
/**
// extract parameters
String from = (String) workItem.getParameter("From");
String to = (String) workItem.getParameter("To");
String message = (String) workItem.getParameter("Message");
String priority = (String) workItem.getParameter("Priority");
// Artificial wait
try {
Thread.sleep(5000);
}
catch (Exception ex) {
}
System.out.println("###work item handler operations###");
session.getWorkItemManager().completeWorkItem(workItem.getId(), null);
//manager.completeWorkItem(workItem.getId(), null);
}
persistence.xml:
<persistence-unit name="test" transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<class>org.jbpm.persistence.processinstance.ProcessInstanceInfo</class>
<class>org.drools.persistence.info.SessionInfo</class>
<class>org.drools.persistence.info.WorkItemInfo</class>
<properties>
<property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect" />
<property name="hibernate.connection.driver_class" value="com.mysql.jdbc.Driver" />
<property name="hibernate.connection.url" value="jdbc:mysql://localhost:3306/test" />
<property name="hibernate.connection.username" value="root" />
<property name="hibernate.connection.password" value="12345" />
<property name="hibernate.connection.autocommit" value="false" />
<property name="hibernate.max_fetch_depth" value="3" />
<property name="hibernate.hbm2ddl.auto" value="create" />
<property name="hibernate.show_sql" value="false" />
<property name="hibernate.transaction.manager_lookup_class"
value="org.hibernate.transaction.BTMTransactionManagerLookup" />
</properties>
</persistence-unit>
</persistence>