|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.dao.jpa.BPELDAOConnectionImpl
public class BPELDAOConnectionImpl
Field Summary | |
---|---|
protected javax.persistence.EntityManager |
_em
|
Constructor Summary | |
---|---|
BPELDAOConnectionImpl(javax.persistence.EntityManager em)
|
Method Summary | |
---|---|
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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected javax.persistence.EntityManager _em
Constructor Detail |
---|
public BPELDAOConnectionImpl(javax.persistence.EntityManager em)
Method Detail |
---|
public java.util.List<BpelEvent> bpelEventQuery(InstanceFilter ifilter, BpelEventFilter efilter)
BpelDAOConnection
bpelEventQuery
in interface BpelDAOConnection
ifilter
- instance filterefilter
- event filter
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 ProcessInstanceDAO getInstance(java.lang.Long iid)
BpelDAOConnection
getInstance
in interface BpelDAOConnection
iid
- instance identifier
public void close()
close
in interface BpelDAOConnection
public MessageExchangeDAO createMessageExchange(char dir)
BpelDAOConnection
createMessageExchange
in interface BpelDAOConnection
dir
- type of message exchange
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 process
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 identifier
public 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
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |