Class JPAMapper
- java.lang.Object
-
- org.jbpm.runtime.manager.impl.mapper.InternalMapper
-
- org.jbpm.runtime.manager.impl.mapper.JPAMapper
-
- All Implemented Interfaces:
org.kie.internal.runtime.manager.Mapper
public class JPAMapper extends InternalMapper
Database based mapper implementation backed by JPA to store the context toKieSessionid mapping. It uses theContextMappingInfoentity for persistence.- See Also:
ContextMappingInfo
-
-
Constructor Summary
Constructors Constructor Description JPAMapper(javax.persistence.EntityManagerFactory emf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ContextMappingInfofindContextByContextId(org.kie.api.runtime.manager.Context context, String ownerId, javax.persistence.EntityManager em)ObjectfindContextId(Long ksessionId, String ownerId)List<String>findContextIdForEvent(String eventType, String ownerId)List<Long>findKSessionToInit(String ownerId)LongfindLogMapping(org.kie.api.runtime.manager.Context<?> context, String ownerId)Finds ksession for given contextLongfindMapping(org.kie.api.runtime.manager.Context context, String ownerId)org.kie.api.runtime.manager.ContextgetProcessInstanceByCorrelationKey(org.kie.internal.process.CorrelationKey correlationKey, javax.persistence.EntityManager em)voidremoveMapping(org.kie.api.runtime.manager.Context context, String ownerId)protected <T> org.kie.api.runtime.manager.Context<T>resolveContext(org.kie.api.runtime.manager.Context orig, javax.persistence.EntityManager em)voidsaveMapping(org.kie.api.runtime.manager.Context context, Long ksessionId, String ownerId)
-
-
-
Method Detail
-
saveMapping
public void saveMapping(org.kie.api.runtime.manager.Context context, Long ksessionId, String ownerId)
-
findLogMapping
public Long findLogMapping(org.kie.api.runtime.manager.Context<?> context, String ownerId)
Description copied from class:InternalMapperFinds ksession for given context- Overrides:
findLogMappingin classInternalMapper- Parameters:
context- instance of the context- Returns:
- ksession identifier when found otherwise null
-
removeMapping
public void removeMapping(org.kie.api.runtime.manager.Context context, String ownerId)
-
resolveContext
protected <T> org.kie.api.runtime.manager.Context<T> resolveContext(org.kie.api.runtime.manager.Context orig, javax.persistence.EntityManager em)
-
findContextByContextId
protected ContextMappingInfo findContextByContextId(org.kie.api.runtime.manager.Context context, String ownerId, javax.persistence.EntityManager em)
-
getProcessInstanceByCorrelationKey
public org.kie.api.runtime.manager.Context getProcessInstanceByCorrelationKey(org.kie.internal.process.CorrelationKey correlationKey, javax.persistence.EntityManager em)
-
findContextIdForEvent
public List<String> findContextIdForEvent(String eventType, String ownerId)
- Specified by:
findContextIdForEventin classInternalMapper
-
-