public class BpelDAOConnectionImpl extends java.lang.Object implements BpelDAOConnection, FilteredInstanceDeletable
BpelDAOConnection
implementation.Modifier and Type | Field and Description |
---|---|
protected SessionManager |
_sm |
Constructor and Description |
---|
BpelDAOConnectionImpl(SessionManager sm) |
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) |
int |
deleteInstances(InstanceFilter criteria,
java.util.Set<ProcessConf.CLEANUP_CATEGORY> categories)
Deletes instance filter by the given instance filter and clean up categories.
|
java.util.Collection<CorrelationSetDAO> |
getActiveCorrelationSets() |
java.util.Map<java.lang.Long,java.util.Collection<CorrelationSetDAO>> |
getCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances) |
ProcessInstanceDAO |
getInstance(java.lang.Long instanceId)
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.
|
protected org.hibernate.Session |
getSession() |
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) |
protected SessionManager _sm
public BpelDAOConnectionImpl(SessionManager sm)
protected org.hibernate.Session getSession()
public MessageExchangeDAO createMessageExchange(char dir)
BpelDAOConnection
createMessageExchange
in interface BpelDAOConnection
dir
- type of message exchangepublic MessageExchangeDAO getMessageExchange(java.lang.String mexid)
getMessageExchange
in interface BpelDAOConnection
public 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 void close()
close
in interface BpelDAOConnection
public ProcessInstanceDAO getInstance(java.lang.Long instanceId)
BpelDAOConnection
getInstance
in interface BpelDAOConnection
instanceId
- instance identifierProcessDAO.getInstance(java.lang.Long)
public 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 java.util.Collection<ProcessInstanceDAO> instanceQuery(InstanceFilter criteria)
BpelDAOConnection
instanceQuery
in interface BpelDAOConnection
public int deleteInstances(InstanceFilter criteria, java.util.Set<ProcessConf.CLEANUP_CATEGORY> categories)
FilteredInstanceDeletable
deleteInstances
in interface FilteredInstanceDeletable
criteria
- instance filtercategories
- clean up categoriespublic 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.List<java.util.Date> bpelEventTimelineQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnection
bpelEventTimelineQuery
in interface BpelDAOConnection
ifilter
- instance filter (optional)efilter
- event filter (optional)public java.util.List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnection
bpelEventQuery
in interface BpelDAOConnection
ifilter
- instance filterefilter
- event filterpublic java.util.Collection<ProcessInstanceDAO> instanceQuery(java.lang.String expression)
instanceQuery
in interface BpelDAOConnection
BpelDAOConnection.instanceQuery(String)
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