public class BPELDAOConnectionImpl extends java.lang.Object implements BpelDAOConnection
Modifier and Type | Field and Description |
---|---|
protected javax.persistence.EntityManager |
_em |
Constructor and Description |
---|
BPELDAOConnectionImpl(javax.persistence.EntityManager em) |
Modifier and Type | Method and Description |
---|---|
java.util.List<BpelEvent> |
bpelEventQuery(InstanceFilter ifilter,
BpelEventFilter efilter)
Execute a query to retrieve the BPEL events matching the criteria.
|
java.util.List<java.util.Date> |
bpelEventTimelineQuery(InstanceFilter ifilter,
BpelEventFilter efilter)
Execute a query for the timeline for BPEL events matching the criteria.
|
void |
close() |
MessageExchangeDAO |
createMessageExchange(char dir)
Create a message exchange.
|
ProcessDAO |
createProcess(javax.xml.namespace.QName pid,
javax.xml.namespace.QName type,
java.lang.String guid,
long version) |
ProcessDAO |
createTransientProcess(java.io.Serializable id) |
void |
deleteMessageExchange(MessageExchangeDAO mexDao) |
java.util.Collection<CorrelationSetDAO> |
getActiveCorrelationSets() |
java.util.Map<java.lang.Long,java.util.Collection<CorrelationSetDAO>> |
getCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances) |
javax.persistence.EntityManager |
getEntityManager() |
ProcessInstanceDAO |
getInstance(java.lang.Long iid)
Retrieve a process instance from the database.
|
MessageExchangeDAO |
getMessageExchange(java.lang.String mexid) |
int |
getNumInstances(javax.xml.namespace.QName processId) |
ProcessDAO |
getProcess(javax.xml.namespace.QName processId)
Return the DAO for a bpel process.
|
ProcessManagementDAO |
getProcessManagement()
Returns an interface for process and instance management.
|
ScopeDAO |
getScope(java.lang.Long siidl)
Retrieve a scope instance from the database.
|
void |
insertBpelEvent(BpelEvent event,
ProcessDAO process,
ProcessInstanceDAO instance)
Insert a BPEL event into the database.
|
java.util.Collection<ProcessInstanceDAO> |
instanceQuery(InstanceFilter criteria)
Query instances in the database meeting the requested
criteria.
|
java.util.Collection<ProcessInstanceDAO> |
instanceQuery(java.lang.String expression) |
void |
setEntityManger(javax.persistence.EntityManager em) |
public BPELDAOConnectionImpl(javax.persistence.EntityManager em)
public java.util.List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnection
bpelEventQuery
in interface BpelDAOConnection
ifilter
- instance filterefilter
- event filterpublic java.util.List<java.util.Date> bpelEventTimelineQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnection
bpelEventTimelineQuery
in interface BpelDAOConnection
ifilter
- instance filter (optional)efilter
- event filter (optional)public ProcessInstanceDAO getInstance(java.lang.Long iid)
BpelDAOConnection
getInstance
in interface BpelDAOConnection
iid
- instance identifierpublic void close()
close
in interface BpelDAOConnection
public MessageExchangeDAO createMessageExchange(char dir)
BpelDAOConnection
createMessageExchange
in interface BpelDAOConnection
dir
- type of message exchangepublic ProcessDAO createProcess(javax.xml.namespace.QName pid, javax.xml.namespace.QName type, java.lang.String guid, long version)
createProcess
in interface BpelDAOConnection
public ProcessDAO createTransientProcess(java.io.Serializable id)
createTransientProcess
in interface BpelDAOConnection
public ProcessDAO getProcess(javax.xml.namespace.QName processId)
BpelDAOConnection
getProcess
in interface BpelDAOConnection
processId
- name (identifier) of the processpublic int getNumInstances(javax.xml.namespace.QName processId)
getNumInstances
in interface BpelDAOConnection
public ScopeDAO getScope(java.lang.Long siidl)
BpelDAOConnection
getScope
in interface BpelDAOConnection
siidl
- scope instance identifierpublic void insertBpelEvent(BpelEvent event, ProcessDAO process, ProcessInstanceDAO instance)
BpelDAOConnection
insertBpelEvent
in interface BpelDAOConnection
event
- a BPEL eventprocess
- associated process (optional)instance
- associated instance (optional)public java.util.Collection<ProcessInstanceDAO> instanceQuery(InstanceFilter criteria)
BpelDAOConnection
instanceQuery
in interface BpelDAOConnection
public java.util.Collection<ProcessInstanceDAO> instanceQuery(java.lang.String expression)
instanceQuery
in interface BpelDAOConnection
public void setEntityManger(javax.persistence.EntityManager em)
public MessageExchangeDAO getMessageExchange(java.lang.String mexid)
getMessageExchange
in interface BpelDAOConnection
public void deleteMessageExchange(MessageExchangeDAO mexDao)
public javax.persistence.EntityManager getEntityManager()
public java.util.Map<java.lang.Long,java.util.Collection<CorrelationSetDAO>> getCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances)
getCorrelationSets
in interface BpelDAOConnection
public java.util.Collection<CorrelationSetDAO> getActiveCorrelationSets()
getActiveCorrelationSets
in interface BpelDAOConnection
public ProcessManagementDAO getProcessManagement()
BpelDAOConnection
getProcessManagement
in interface BpelDAOConnection