org.apache.ode.dao.jpa
Class MessageExchangeDAOImpl

java.lang.Object
  extended by org.apache.ode.dao.jpa.OpenJPADAO
      extended by 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


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

Field Detail

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
Constructor Detail

MessageExchangeDAOImpl

public MessageExchangeDAOImpl()

MessageExchangeDAOImpl

public MessageExchangeDAOImpl(char direction)
Method Detail

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