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)
BpelDAOConnectioncreateMessageExchange in interface BpelDAOConnectiondir - type of message exchangepublic MessageExchangeDAO getMessageExchange(java.lang.String mexid)
getMessageExchange in interface BpelDAOConnectionpublic ProcessDAO createProcess(javax.xml.namespace.QName pid, javax.xml.namespace.QName type, java.lang.String guid, long version)
createProcess in interface BpelDAOConnectionpublic ProcessDAO createTransientProcess(java.io.Serializable id)
createTransientProcess in interface BpelDAOConnectionpublic ProcessDAO getProcess(javax.xml.namespace.QName processId)
BpelDAOConnectiongetProcess in interface BpelDAOConnectionprocessId - name (identifier) of the processpublic void close()
close in interface BpelDAOConnectionpublic ProcessInstanceDAO getInstance(java.lang.Long instanceId)
BpelDAOConnectiongetInstance in interface BpelDAOConnectioninstanceId - instance identifierProcessDAO.getInstance(java.lang.Long)public int getNumInstances(javax.xml.namespace.QName processId)
getNumInstances in interface BpelDAOConnectionpublic ScopeDAO getScope(java.lang.Long siidl)
BpelDAOConnectiongetScope in interface BpelDAOConnectionsiidl - scope instance identifierpublic java.util.Collection<ProcessInstanceDAO> instanceQuery(InstanceFilter criteria)
BpelDAOConnectioninstanceQuery in interface BpelDAOConnectionpublic int deleteInstances(InstanceFilter criteria, java.util.Set<ProcessConf.CLEANUP_CATEGORY> categories)
FilteredInstanceDeletabledeleteInstances in interface FilteredInstanceDeletablecriteria - instance filtercategories - clean up categoriespublic void insertBpelEvent(BpelEvent event, ProcessDAO process, ProcessInstanceDAO instance)
BpelDAOConnectioninsertBpelEvent in interface BpelDAOConnectionevent - a BPEL eventprocess - associated process (optional)instance - associated instance (optional)public java.util.List<java.util.Date> bpelEventTimelineQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnectionbpelEventTimelineQuery in interface BpelDAOConnectionifilter - instance filter (optional)efilter - event filter (optional)public java.util.List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnectionbpelEventQuery in interface BpelDAOConnectionifilter - instance filterefilter - event filterpublic java.util.Collection<ProcessInstanceDAO> instanceQuery(java.lang.String expression)
instanceQuery in interface BpelDAOConnectionBpelDAOConnection.instanceQuery(String)public java.util.Map<java.lang.Long,java.util.Collection<CorrelationSetDAO>> getCorrelationSets(java.util.Collection<ProcessInstanceDAO> instances)
getCorrelationSets in interface BpelDAOConnectionpublic java.util.Collection<CorrelationSetDAO> getActiveCorrelationSets()
getActiveCorrelationSets in interface BpelDAOConnectionpublic ProcessManagementDAO getProcessManagement()
BpelDAOConnectiongetProcessManagement in interface BpelDAOConnection