org.apache.ode.dao.jpa
Class MessageExchangeDAOImpl
java.lang.Object
org.apache.ode.dao.jpa.OpenJPADAO
org.apache.ode.dao.jpa.MessageExchangeDAOImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.dao.CorrelatorMessageDAO, org.apache.ode.bpel.dao.MessageExchangeDAO
public class MessageExchangeDAOImpl
- extends OpenJPADAO
- implements org.apache.ode.bpel.dao.MessageExchangeDAO, org.apache.ode.bpel.dao.CorrelatorMessageDAO
Fields inherited from interface org.apache.ode.bpel.dao.MessageExchangeDAO |
DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DELETE_MEXS_BY_PROCESS
public static final java.lang.String DELETE_MEXS_BY_PROCESS
- See Also:
- Constant Field Values
SELECT_MEX_IDS_BY_PROCESS
public static final java.lang.String SELECT_MEX_IDS_BY_PROCESS
- See Also:
- Constant Field Values
MessageExchangeDAOImpl
public MessageExchangeDAOImpl()
MessageExchangeDAOImpl
public MessageExchangeDAOImpl(char direction)
createMessage
public org.apache.ode.bpel.dao.MessageDAO createMessage(javax.xml.namespace.QName type)
- Specified by:
createMessage
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getCallee
public javax.xml.namespace.QName getCallee()
- Specified by:
getCallee
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getChannel
public java.lang.String getChannel()
- Specified by:
getChannel
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getCorrelationId
public java.lang.String getCorrelationId()
- Specified by:
getCorrelationId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getCorrelationStatus
public java.lang.String getCorrelationStatus()
- Specified by:
getCorrelationStatus
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getCreateTime
public java.util.Date getCreateTime()
- Specified by:
getCreateTime
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getDirection
public char getDirection()
- Specified by:
getDirection
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getEPR
public org.w3c.dom.Element getEPR()
- Specified by:
getEPR
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getFault
public javax.xml.namespace.QName getFault()
- Specified by:
getFault
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getFaultExplanation
public java.lang.String getFaultExplanation()
- Specified by:
getFaultExplanation
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getInstance
public org.apache.ode.bpel.dao.ProcessInstanceDAO getInstance()
- Specified by:
getInstance
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getMessageExchangeId
public java.lang.String getMessageExchangeId()
- Specified by:
getMessageExchangeId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getOperation
public java.lang.String getOperation()
- Specified by:
getOperation
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPartnerLink
public org.apache.ode.bpel.dao.PartnerLinkDAO getPartnerLink()
- Specified by:
getPartnerLink
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPartnerLinkModelId
public int getPartnerLinkModelId()
- Specified by:
getPartnerLinkModelId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPattern
public java.lang.String getPattern()
- Specified by:
getPattern
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPortType
public javax.xml.namespace.QName getPortType()
- Specified by:
getPortType
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getProcess
public org.apache.ode.bpel.dao.ProcessDAO getProcess()
- Specified by:
getProcess
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPropagateTransactionFlag
public boolean getPropagateTransactionFlag()
- Specified by:
getPropagateTransactionFlag
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getProperty
public java.lang.String getProperty(java.lang.String key)
- Specified by:
getProperty
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPropertyNames
public java.util.Set<java.lang.String> getPropertyNames()
- Specified by:
getPropertyNames
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getRequest
public org.apache.ode.bpel.dao.MessageDAO getRequest()
- Specified by:
getRequest
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getResponse
public org.apache.ode.bpel.dao.MessageDAO getResponse()
- Specified by:
getResponse
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getStatus
public java.lang.String getStatus()
- Specified by:
getStatus
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setCallee
public void setCallee(javax.xml.namespace.QName callee)
- Specified by:
setCallee
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setChannel
public void setChannel(java.lang.String channel)
- Specified by:
setChannel
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setCorrelationId
public void setCorrelationId(java.lang.String correlationId)
- Specified by:
setCorrelationId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setCorrelationStatus
public void setCorrelationStatus(java.lang.String cstatus)
- Specified by:
setCorrelationStatus
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setEPR
public void setEPR(org.w3c.dom.Element epr)
- Specified by:
setEPR
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setFault
public void setFault(javax.xml.namespace.QName faultType)
- Specified by:
setFault
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setFaultExplanation
public void setFaultExplanation(java.lang.String explanation)
- Specified by:
setFaultExplanation
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setInstance
public void setInstance(org.apache.ode.bpel.dao.ProcessInstanceDAO dao)
- Specified by:
setInstance
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setOperation
public void setOperation(java.lang.String opname)
- Specified by:
setOperation
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setPartnerLink
public void setPartnerLink(org.apache.ode.bpel.dao.PartnerLinkDAO plinkDAO)
- Specified by:
setPartnerLink
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setPartnerLinkModelId
public void setPartnerLinkModelId(int modelId)
- Specified by:
setPartnerLinkModelId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setPattern
public void setPattern(java.lang.String pattern)
- Specified by:
setPattern
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setPortType
public void setPortType(javax.xml.namespace.QName porttype)
- Specified by:
setPortType
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setProcess
public void setProcess(org.apache.ode.bpel.dao.ProcessDAO process)
- Specified by:
setProcess
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setProperty
public void setProperty(java.lang.String key,
java.lang.String value)
- Specified by:
setProperty
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setRequest
public void setRequest(org.apache.ode.bpel.dao.MessageDAO msg)
- Specified by:
setRequest
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setResponse
public void setResponse(org.apache.ode.bpel.dao.MessageDAO msg)
- Specified by:
setResponse
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setStatus
public void setStatus(java.lang.String status)
- Specified by:
setStatus
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getPipedMessageExchangeId
public java.lang.String getPipedMessageExchangeId()
- Specified by:
getPipedMessageExchangeId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setPipedMessageExchangeId
public void setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
- Specified by:
setPipedMessageExchangeId
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
getCorrelationKey
public org.apache.ode.bpel.common.CorrelationKey getCorrelationKey()
- Specified by:
getCorrelationKey
in interface org.apache.ode.bpel.dao.CorrelatorMessageDAO
setCorrelationKey
public void setCorrelationKey(org.apache.ode.bpel.common.CorrelationKey ckey)
- Specified by:
setCorrelationKey
in interface org.apache.ode.bpel.dao.CorrelatorMessageDAO
release
public void release(boolean doClean)
- Specified by:
release
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
releasePremieMessages
public void releasePremieMessages()
- Specified by:
releasePremieMessages
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
deleteMessages
public void deleteMessages()
getCorrelator
public CorrelatorDAOImpl getCorrelator()
setCorrelator
public void setCorrelator(CorrelatorDAOImpl correlator)
getSubscriberCount
public int getSubscriberCount()
- Specified by:
getSubscriberCount
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
setSubscriberCount
public void setSubscriberCount(int subscriberCount)
- Specified by:
setSubscriberCount
in interface org.apache.ode.bpel.dao.MessageExchangeDAO
incrementSubscriberCount
public void incrementSubscriberCount()
release
public void release()
setCreateTime
public void setCreateTime(java.util.Date createTime)
- Specified by:
setCreateTime
in interface org.apache.ode.bpel.dao.MessageExchangeDAO