JBoss Community

JBPM5.4 with MySQL with CustomTaskService

created by chakri_7 in jBPM - View the full discussion

I am using CustomeTaskService as TaskService Provider, IN JBPM 5.4

public class DemoTaskService {

public static void main(String[] args) {

EntityManagerFactory emf = Persistence.createEntityManagerFactory("org.jbpm.task");

TaskService taskService = new TaskService(emf, SystemEventListenerFactory.getSystemEventListener());

TaskServiceSession taskSession = taskService.createSession();

// Add users

taskSession.addUser(new User("krisv"));

taskSession.addUser(new User("john"));

Map vars = new HashMap();

InputStream usersin = DemoTaskService.class.getResourceAsStream("/LoadUsers.mvel");

if(usersin != null) {

Reader reader = new InputStreamReader( usersin );

@SuppressWarnings("unchecked")

Map<String, User> users = ( Map<String, User> ) TaskService.eval( reader, vars );

for ( User user : users.values() ) {

System.out.println("Adding user: "+user);

taskSession.addUser( user );

}

InputStream groupsin = DemoTaskService.class.getResourceAsStream("/LoadGroups.mvel");

if(groupsin != null) {

Reader reader = new InputStreamReader( groupsin );

@SuppressWarnings("unchecked")

Map<String, Group> groups = ( Map<String, Group> ) TaskService.eval( reader, vars );

for ( Group group : groups.values() ) {

System.out.println("Adding group: "+group);

taskSession.addGroup( group );

}

// try to get the usergroup callback properties

InputStream usergroupsin = DemoTaskService.class.getResourceAsStream("/jbpm.usergroup.callback.properties");

if(usergroupsin != null) {

Properties callbackproperties = new Properties();

try {

// Properties.load(Reader) is a JDK 6 method

System.out.println("Loading usergroupsin: "+usergroupsin);

callbackproperties.load(usergroupsin);

UserGroupCallbackManager.getInstance().setCallbackFromProperties(callbackproperties);

System.out.println("Task service registered usergroup callback ...");

} catch (Exception e) {

System.out.println("Task service unable to register usergroup callback ...");

}

// start server

MinaTaskServer server = new MinaTaskServer(taskService,9988);

Thread thread = new Thread(server);

thread.start();

taskSession.dispose();

System.out.println("Task service started correctly!");

System.out.println("Task service running ...");

}

And JBPM process as,

public static final void main(String[] args) {

try {

EntityManagerFactory emf = Persistence.createEntityManagerFactory( "org.jbpm.task" );

Environment env = KnowledgeBaseFactory.newEnvironment();

env.set( EnvironmentName.ENTITY_MANAGER_FACTORY, emf );

env.set( EnvironmentName.TRANSACTION_MANAGER, TransactionManagerServices.getTransactionManager());

env.set( EnvironmentName.GLOBALS, new MapGlobalResolver() );*/

// load up the knowledge base

KnowledgeBase kbase = readKnowledgeBase();

StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();

//StatefulKnowledgeSession ksession = JPAKnowledgeService.newStatefulKnowledgeSession( kbase, null, env );

KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newFileLogger(ksession, "test");

WSHumanTaskHandler wsTaskHandler = new WSHumanTaskHandler();

wsTaskHandler.setConnection("127.0.0.1", 9988);

CommandBasedWSHumanTaskHandler cmdTaskHandler = new CommandBasedWSHumanTaskHandler();

cmdTaskHandler.setConnection("127.0.0.1", 9988);

cmdTaskHandler.setSession(ksession);

//Map params = new HashMap();

//params.put("employee", "krisv");

//UserTransaction ut = (UserTransaction) new InitialContext().lookup("java:comp/UserTransaction");

//ut.begin();

ksession.getWorkItemManager().registerWorkItemHandler("Human Task", cmdTaskHandler);

// start a new process instance

ksession.startProcess("humantask.demo");

// commit the transaction

//ut.commit();

logger.close();

} catch (Throwable t) {

System.out.println(t.getCause());

t.printStackTrace();

}

in Task Service End I get,

Loading usergroupsin: sun.net.www.protocol.jar.JarURLConnection$JarURLInputStream@67e54826

Task service registered usergroup callback ...

Task service started correctly!

Task service running ...

0 29/07 07:18:13,164[NioProcessor-1] ERROR hibernate.util.JDBCExceptionReporter.logExceptions - Cannot add or update a child row: a foreign key constraint fails (`task`.`peopleassignments_bas`, CONSTRAINT `FK9D8CF4EC2C122ED2` FOREIGN KEY (`entity_id`) REFERENCES `organizationalentity` (`id`))

3 29/07 07:18:13,167[NioProcessor-1] ERROR event.def.AbstractFlushingEventListener.performExecutions - Could not synchronize database state with session

org.hibernate.exception.ConstraintViolationException: Could not execute JDBC batch update

at org.hibernate.exception.SQLStateConverter.convert(SQLStateConverter.java:94)

at org.hibernate.exception.JDBCExceptionHelper.convert(JDBCExceptionHelper.java:66)

at org.hibernate.jdbc.AbstractBatcher.executeBatch(AbstractBatcher.java:275)

at org.hibernate.jdbc.AbstractBatcher.prepareStatement(AbstractBatcher.java:114)

at org.hibernate.jdbc.AbstractBatcher.prepareStatement(AbstractBatcher.java:109)

at org.hibernate.jdbc.AbstractBatcher.prepareBatchStatement(AbstractBatcher.java:244)

at org.hibernate.persister.collection.AbstractCollectionPersister.recreate(AbstractCollectionPersister.java:1141)

at org.hibernate.action.CollectionRecreateAction.execute(CollectionRecreateAction.java:58)

at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:279)

at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:263)

at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:171)

at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321)

at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:50)

at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1028)

at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:366)

at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:137)

at org.hibernate.ejb.TransactionImpl.commit(TransactionImpl.java:54)

at org.jbpm.task.service.persistence.TaskLocalTransactionManager.commit(TaskLocalTransactionManager.java:55)

at org.jbpm.task.service.persistence.TaskPersistenceManager.endTransaction(TaskPersistenceManager.java:107)

at org.jbpm.task.service.TaskServiceSession.doOperationInTransaction(TaskServiceSession.java:1118)

at org.jbpm.task.service.TaskServiceSession.addTask(TaskServiceSession.java:189)

at org.jbpm.task.service.TaskServerHandler.messageReceived(TaskServerHandler.java:151)

at org.jbpm.task.service.mina.MinaTaskServerHandler.messageReceived(MinaTaskServerHandler.java:41)

at org.apache.mina.core.filterchain.DefaultIoFilterChain$TailFilter.messageReceived(DefaultIoFilterChain.java:713)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:46)

at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:793)

at org.apache.mina.filter.codec.ProtocolCodecFilter$ProtocolDecoderOutputImpl.flush(ProtocolCodecFilter.java:375)

at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:229)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:46)

at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:793)

at org.apache.mina.filter.logging.LoggingFilter.messageReceived(LoggingFilter.java:176)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:46)

at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:793)

at org.apache.mina.core.filterchain.IoFilterAdapter.messageReceived(IoFilterAdapter.java:119)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)

at org.apache.mina.core.filterchain.DefaultIoFilterChain.fireMessageReceived(DefaultIoFilterChain.java:426)

at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:638)

at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:598)

at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:587)

at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$400(AbstractPollingIoProcessor.java:61)

at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:969)

at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)

at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

at java.lang.Thread.run(Unknown Source)

Caused by: java.sql.BatchUpdateException: Cannot add or update a child row: a foreign key constraint fails (`task`.`peopleassignments_bas`, CONSTRAINT `FK9D8CF4EC2C122ED2` FOREIGN KEY (`entity_id`) REFERENCES `organizationalentity` (`id`))

at com.mysql.jdbc.PreparedStatement.executeBatchSerially(PreparedStatement.java:2007)

at com.mysql.jdbc.PreparedStatement.executeBatch(PreparedStatement.java:1443)

at org.hibernate.jdbc.BatchingBatcher.doExecuteBatch(BatchingBatcher.java:70)

at org.hibernate.jdbc.AbstractBatcher.executeBatch(AbstractBatcher.java:268)

... 45 more

25 29/07 07:18:13,189[NioProcessor-1] WARN service.persistence.TaskLocalTransactionManager.commit - Unable to commit transaction

javax.persistence.RollbackException: Error while commiting the transaction

at org.hibernate.ejb.TransactionImpl.commit(TransactionImpl.java:71)