topic Re: Activiti Engine and container-managed entity manager in Alfresco Archive

Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 09:20:09 GMT

Is it possible to configure Activiti engine to use container-managed entity manager(em) whenI invoke Activiti API in EJB method?@PersistenceContext(name = "persistence/SKO_EM")private EntityManager em;public testEJBMethod() { //invoke Activiti API - I want Activiti engine to use em injected via anno

Re: Activiti Engine and container-managed entity manager

frederikherema1 — Mon, 20 Jun 2011 11:48:00 GMT

Did you read the topic about JPA in the userguide? You should check out the examples as well (JPAVariableTest I think it's called).

Activiti allows you to set the EntyManagerFactory to use when using JPA-entities as variable.

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 12:24:14 GMT

Hi Frederik,

Activiti engine get Entity Manager via call javax.persistence.Persistence.createEntityManagerFactory("unit").createEntityManager().
I examined sources of Activiti.

But when I use container-managed persistence in EJB, i dont need to get EM from factoty or create factory.
I use @PersistenceContext annotation.

@PersistenceContext(name = "persistence/SKO_EM")
private EntityManager em;

Suppose I invoke Activiti API in EJB method and engine update JPA variable internally (i created such process in designer).
Then I update same JPA variable in same EJB method outside engine API call. I am using Entity Manager getted from
annotation.

Problem: Activity Engine uses another Entity Manager. I dont see any ability to ask engine use my Entity manager. Engine always
call createEntityManager() and create new Entity Manager.

Lis

Re: Activiti Engine and container-managed entity manager

frederikherema1 — Mon, 20 Jun 2011 12:29:29 GMT

Doesn't EJB provide entity-manager factories (proxies) who reuse the same EnitityManager instance, as long as the transaction is running in the same thread? (sorry, has been a while since I did EJB stuff )

If not, I don't see another option than writing your own solution or suggest one to us that is more flexible (and not restricting) than the one we have now… But you saw the code for wiring in the JPA-stuff, that's a good starting point.

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 12:51:50 GMT

We are using WebSphere App Server 7.0.
Entity manager getted from annotation and via createEntityManager in the same thread differrent.
I created sample entity and invoked em.contains(sampleEntity) to check this.

May be this only in WAS container and some containers provide Entity Manager propagation feature
in the same thread.

Re: Activiti Engine and container-managed entity manager

frederikherema1 — Mon, 20 Jun 2011 12:55:37 GMT

Than I'm affraid you're on your own But hooking into custom Entity-manager lookup shouldn't be that hard, you can do it in your codebase. Take a look al org.activiti.engine.impl.variable.EntityManagerSession, EMSFactory, … etc. You can find examples on forum on how to plug your own sessions in activiti config…

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 13:34:59 GMT

Solution for Container-Managed Entity Manager:

1) Do not use Persistence.createEntityManagerFactory("UNIT_NAME").createEntityManager();
2) If Entity manager injected in EJB with @PersistenceContext(name = "persistence/UNIT_NAME") private EntityManager em; annotation
EJB, than to find same entity manager in Activiti Engine code use next code:

InitialContext ctx = new InitialContext();
EntityManager em = (EntityManager) ctx
    .lookup("java:comp/env/persistence/UNIT_NAME");

I think best place for this lookup in EntityManagerSessionFactory.openSession() .

public Session openSession() {
              InitialContext ctx = new InitialContext();
EntityManager entityManager = (EntityManager) ctx
    .lookup("java:comp/env/persistence/UNIT_NAME");
    return new EntityManagerSessionImpl(null, entityManager, handleTransactions, closeEntityManager);
}

3) Set handleTransactions = false, closeEntityManager = false

Lis

Re: Activiti Engine and container-managed entity manager

frederikherema1 — Mon, 20 Jun 2011 13:37:22 GMT

That look good, thanks for sharing!

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 14:32:12 GMT

Is it possible to include this in future releases of ACTIVITI? I think It was good
to have configuration variable like ejbContainerManagedEM = true/false to switch
to another EM lookup method.

In current release (5.6) I need to do:

1) Create new impementation org.activiti.engine.impl.interceptor.SessionFactory and implement
EM lookup in openSession method().
2) Override initJPA() in ProcessEngineConfigurationImpl

protected void initJpa() {

   sessionFactories.put(EntityManagerSession.class,
     new MY_EntityManagerSessionFactory(jpaEntityManagerFactory,
       jpaHandleTransaction, jpaCloseEntityManager));
   VariableType jpaType = variableTypes
     .getVariableType(JPAEntityVariableType.TYPE_NAME);
   // Add JPA-type
   if (jpaType == null) {
    // We try adding the variable right before SerializableType, if
    // available
    int serializableIndex = variableTypes
      .getTypeIndex(SerializableType.TYPE_NAME);
    if (serializableIndex > -1) {
     variableTypes.addType(new JPAEntityVariableType(),
       serializableIndex);
    } else {
     variableTypes.addType(new JPAEntityVariableType());
    }
   }
}

Not very clear solution.

Re: Activiti Engine and container-managed entity manager

frederikherema1 — Mon, 20 Jun 2011 14:40:24 GMT

You can plug in an alternative factory in your OWN configuration, not in activiti-code.

You suggest creating a parameter with the jndi-name of the entity-manager? (because this ofcourse depends on the environnement)

You can always contribute a patch of this kind of solution, if you want…

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 14:54:35 GMT

jndi name = "java:comp/env/" + UNIT_NAME,
UNIT_NAME we can get from configuration variable ProcessEngineConfiguration.getJpaPersistenceUnitName().

Re: Activiti Engine and container-managed entity manager

lis — Mon, 20 Jun 2011 15:14:24 GMT

If I write @PersistenceContext(name = "UNIT_NAME") private EntityManager em;
in EJB, than container MAY create JNDI reference with name "java:comp/env/UNIT_NAME",
but NOT REQUIRED by specification.

Re: Activiti Engine and container-managed entity manager

p4w3l — Tue, 23 Aug 2016 17:31:29 GMT

Trying already 3 weeks to implement custom EntityManagerSessionFactory w/o success. Please advice how to do it.
Need to have same entity manager in EJB and Activiti.

<java>
public class CMPEntityManagerSessionFactory implements SessionFactory {

public Class<?> getSessionType() {
return EntityManagerSession.class;
}

private EntityManager lookupEntityManager() {
try {
   return InitialContext.doLookup("java:jboss/myEntityManager");
} catch (NamingException e) {
   throw new RuntimeException("Unable to lookup entity manager.", e);
}
}

public Session openSession() {
return new EntityManagerSessionImpl( null, lookupEntityManager(), false, false );
}

}
</java>

I start Process engine with ProcessEngineLookup :

<java>
public ProcessEngine getProcessEngine() {

CdiJtaProcessEngineConfiguration processEngineConfiguration = new CdiJtaProcessEngineConfiguration();
processEngineConfiguration.setProcessEngineName("default");
processEngineConfiguration.setDataSourceJndiName("java:jboss/datasources/ACTIVITD");
processEngineConfiguration.setTransactionManager( lookupTransactionManager() );
processEngineConfiguration.setDatabaseSchemaUpdate( ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE );
processEngineConfiguration.setHistory( HistoryLevel.FULL.getKey() );

ArrayList<BpmnParseHandler> handlers = new ArrayList<BpmnParseHandler>();
handlers.add( new org.activiti.cdi.impl.event.CdiEventSupportBpmnParseHandler() );
processEngineConfiguration.setPostBpmnParseHandlers( handlers );

processEngineConfiguration.setJobExecutorActivate(true);

// processEngineConfiguration.setJpaEntityManagerFactory( lookupEntityManagerFactory() );
processEngineConfiguration.setTransactionsExternallyManaged( true );
processEngineConfiguration.setJpaHandleTransaction( false );
processEngineConfiguration.setJpaCloseEntityManager( false );

processEngine = processEngineConfiguration.buildProcessEngine();

List<SessionFactory> sessionFactories = sessionFactories = new ArrayList<SessionFactory>();
sessionFactories.add( new LdapUserManagerFactory() );
sessionFactories.add( new CMPEntityManagerSessionFactory() );
if( processEngineConfiguration.getCustomSessionFactories() == null )
   processEngineConfiguration.setCustomSessionFactories( sessionFactories );
else
   processEngineConfiguration.getCustomSessionFactories().addAll( sessionFactories );
processEngine = processEngineConfiguration.buildProcessEngine();
return processEngine;
}
</java>

and having:

<code>
org.activiti.engine.ActivitiException: unknown variable type name jpa-entity
</code>