topic Re: Update custom tables along with Activiti Tables in Alfresco Archive

Update custom tables along with Activiti Tables

subashini — Mon, 06 Jun 2016 14:14:42 GMT

We are updating custom table using listener in the user task, service task and Email task , as part of our workflow. We are using the same transaction manager for both Activiti and the Custom tables. But even then, when there is a error in the listener, Activiti is not getting committed, but the loc

Re: Update custom tables along with Activiti Tables

hari — Wed, 08 Jun 2016 05:13:13 GMT

I would prefer going for a service task if there are chances of exception in task listeners.

Re: Update custom tables along with Activiti Tables

subashini — Wed, 08 Jun 2016 14:26:08 GMT

The same behavior is seen for service task.

Re: Update custom tables along with Activiti Tables

jbarrez — Mon, 20 Jun 2016 12:01:12 GMT

Can you post your delegate? Is it a Spring bean? Are the other services injected into it?
A process xml would also help.

Re: Update custom tables along with Activiti Tables

subashini — Mon, 20 Jun 2016 14:05:26 GMT

This is my execution listener.
public class TMCWFNotificationListener implements ExecutionListener {
private Expression assignedTo;
private Expression message;
private Expression ds;

Logger logger = LoggerFactory.getLogger(TMCWFNotificationListener.class);
@Override
public void notify(DelegateExecution arg0) throws Exception{
// TODO Auto-generated method stub
int entityId = 0;
String assignee = "",messageval = "";

NotificationObject notifyObj = new NotificationObject();
WorkflowDbDAOImpl jdbcDAO = (WorkflowDbDAOImpl) ds.getValue(arg0);

String entityIdString = (String) arg0.getVariable("EntityId");

notifyObj.setEntitytype(entityType);
notifyObj.setEntityid(entityId);
notifyObj.setAssignedto(assignee);
notifyObj.setMessage(messageval);

logger.info("Inside notification Listener");

jdbcDAO.insertNotifications(notifyObj);
}

}

I am injecting the values to this is listener from my Process.

ds - ${workflowDbDAO}
assignedTo ${reminderobj.email}
message - Reminder - ${stepMessage} Notification

Re: Update custom tables along with Activiti Tables

davanna — Mon, 20 Jun 2016 21:50:31 GMT

I had similar questions. In my case, I was using Spring boot application. I was using a transactionManager auto injected with my data source pointing to my tables. The transaction manager is a JPATransactionManager implementation. I was updating the tables in the event listeners. The same transaction manager along with a datasource pointing to activiti tables was passed to initialize the SpringProcessEngineConfiguration. The behavior is proper and working fine. The activiti engine underneath it uses Mybatis and uses the datasource passed to it accordingly. But my question is that how we can use the same transaction manager for two different data sources. The Spring documentation says that JpaTransactionManager must be used with one datasource. I have asked this question here - https://forums.activiti.org/content/multiple-data-sources-activiti

In your case, you are using the same datsource for both the updates i.e. your tables as well as activiti. Basically you have defined your tables in the same schema as the activiti. In my case, I have defined the tables in different schemas respectively for activiti and my tables.

Re: Update custom tables along with Activiti Tables

subashini — Tue, 21 Jun 2016 14:37:28 GMT

Thank you for sharing your use case. I am using just a single datasource, but still the transactions are getting committed seperately. Initially, we used seperate data source. Then I modified to use the same datasource, but still it is not working.

How did you inject the transaction manager to the event listeners?

Re: Update custom tables along with Activiti Tables

jbarrez — Wed, 22 Jun 2016 08:22:59 GMT

Your TMCWFNotificationListener needs to be a spring bean too … or it won't participate in the same transaction. You need to reference it in your process via an expression. And then you can simply @AutoWired your dependencies like the DAO class you're using.