org.apache.ode.bpel.memdao

Class MessageExchangeDAOImpl

java.lang.Object

org.apache.ode.bpel.memdao.MessageExchangeDAOImpl

All Implemented Interfaces:

MessageExchangeDAO

public class MessageExchangeDAOImpl
extends java.lang.Object
implements MessageExchangeDAO

Field Summary

Fields inherited from interface org.apache.ode.bpel.dao.MessageExchangeDAO

DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE

Constructor Summary

Constructors

Constructor and Description
MessageExchangeDAOImpl(char direction, java.lang.String messageEchangeId)

Method Summary

Modifier and Type	Method and Description
MessageDAO	createMessage(javax.xml.namespace.QName type)
java.util.Collection<AttachmentDAO>	getAttachments()
org.w3c.dom.Element	getCallbackEPR()
javax.xml.namespace.QName	getCallee()
java.lang.String	getChannel()
java.lang.String	getCorrelationId()
java.lang.String	getCorrelationStatus()
java.util.Date	getCreateTime()
char	getDirection()
org.w3c.dom.Element	getEPR()
javax.xml.namespace.QName	getFault()
java.lang.String	getFaultExplanation()
ProcessInstanceDAO	getInstance()
java.lang.String	getMessageExchangeId()
java.lang.String	getOperation()
PartnerLinkDAO	getPartnerLink()
int	getPartnerLinkModelId()
java.lang.String	getPattern()
java.lang.String	getPipedMessageExchangeId()
javax.xml.namespace.QName	getPortType()
ProcessDAO	getProcess()
boolean	getPropagateTransactionFlag()
java.lang.String	getProperty(java.lang.String key)
java.util.Set<java.lang.String>	getPropertyNames()
MessageDAO	getRequest()
MessageDAO	getResponse()
java.lang.String	getStatus()
int	getSubscriberCount()
void	incrementSubscriberCount()
boolean	lockPremieMessages()
void	release(boolean doClean)
void	releasePremieMessages()
void	setAttachments(java.util.Collection<AttachmentDAO> attachments)
void	setCallbackEPR(org.w3c.dom.Element epr)
void	setCallee(javax.xml.namespace.QName callee)
void	setChannel(java.lang.String string)
void	setCorrelationId(java.lang.String correlationId)
void	setCorrelationStatus(java.lang.String cstatus)
void	setCreateTime(java.util.Date d)
void	setEPR(org.w3c.dom.Element epr)
void	setFault(javax.xml.namespace.QName faultType)
void	setFaultExplanation(java.lang.String explanation)
void	setInstance(ProcessInstanceDAO dao)
void	setOperation(java.lang.String opname)
void	setPartnerLink(PartnerLinkDAO plinkDAO)
void	setPartnerLinkModelId(int modelId)
void	setPattern(java.lang.String string)
void	setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
void	setPortType(javax.xml.namespace.QName porttype)
void	setProcess(ProcessDAO process)
void	setProperty(java.lang.String key, java.lang.String value)
void	setRequest(MessageDAO msg)
void	setResponse(MessageDAO msg)
void	setStatus(java.lang.String status)
void	setSubscriberCount(int subscriberCount)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageExchangeDAOImpl

public MessageExchangeDAOImpl(char direction,
                              java.lang.String messageEchangeId)

Method Detail

getMessageExchangeId

public java.lang.String getMessageExchangeId()

Specified by:

getMessageExchangeId in interface MessageExchangeDAO

getResponse

public MessageDAO getResponse()

Specified by:

getResponse in interface MessageExchangeDAO

getCreateTime

public java.util.Date getCreateTime()

Specified by:

getCreateTime in interface MessageExchangeDAO

setCreateTime

public void setCreateTime(java.util.Date d)

Specified by:

setCreateTime in interface MessageExchangeDAO

getRequest

public MessageDAO getRequest()

Specified by:

getRequest in interface MessageExchangeDAO

getOperation

public java.lang.String getOperation()

Specified by:

getOperation in interface MessageExchangeDAO

getPortType

public javax.xml.namespace.QName getPortType()

Specified by:

getPortType in interface MessageExchangeDAO

setPortType

public void setPortType(javax.xml.namespace.QName porttype)

Specified by:

setPortType in interface MessageExchangeDAO

setStatus

public void setStatus(java.lang.String status)

Specified by:

setStatus in interface MessageExchangeDAO

getStatus

public java.lang.String getStatus()

Specified by:

getStatus in interface MessageExchangeDAO

createMessage

public MessageDAO createMessage(javax.xml.namespace.QName type)

Specified by:

createMessage in interface MessageExchangeDAO

setRequest

public void setRequest(MessageDAO msg)

Specified by:

setRequest in interface MessageExchangeDAO

setResponse

public void setResponse(MessageDAO msg)

Specified by:

setResponse in interface MessageExchangeDAO

getPartnerLinkModelId

public int getPartnerLinkModelId()

Specified by:

getPartnerLinkModelId in interface MessageExchangeDAO

setPartnerLinkModelId

public void setPartnerLinkModelId(int modelId)

Specified by:

setPartnerLinkModelId in interface MessageExchangeDAO

getCorrelationId

public java.lang.String getCorrelationId()

Specified by:

getCorrelationId in interface MessageExchangeDAO

setCorrelationId

public void setCorrelationId(java.lang.String correlationId)

Specified by:

setCorrelationId in interface MessageExchangeDAO

setPattern

public void setPattern(java.lang.String string)

Specified by:

setPattern in interface MessageExchangeDAO

setOperation

public void setOperation(java.lang.String opname)

Specified by:

setOperation in interface MessageExchangeDAO

setEPR

public void setEPR(org.w3c.dom.Element epr)

Specified by:

setEPR in interface MessageExchangeDAO

getEPR

public org.w3c.dom.Element getEPR()

Specified by:

getEPR in interface MessageExchangeDAO

setCallbackEPR

public void setCallbackEPR(org.w3c.dom.Element epr)

getCallbackEPR

public org.w3c.dom.Element getCallbackEPR()

getPattern

public java.lang.String getPattern()

Specified by:

getPattern in interface MessageExchangeDAO

getChannel

public java.lang.String getChannel()

Specified by:

getChannel in interface MessageExchangeDAO

setChannel

public void setChannel(java.lang.String string)

Specified by:

setChannel in interface MessageExchangeDAO

getPropagateTransactionFlag

public boolean getPropagateTransactionFlag()

Specified by:

getPropagateTransactionFlag in interface MessageExchangeDAO

getFault

public javax.xml.namespace.QName getFault()

Specified by:

getFault in interface MessageExchangeDAO

setFault

public void setFault(javax.xml.namespace.QName faultType)

Specified by:

setFault in interface MessageExchangeDAO

getFaultExplanation

public java.lang.String getFaultExplanation()

Specified by:

getFaultExplanation in interface MessageExchangeDAO

setFaultExplanation

public void setFaultExplanation(java.lang.String explanation)

Specified by:

setFaultExplanation in interface MessageExchangeDAO

setCorrelationStatus

public void setCorrelationStatus(java.lang.String cstatus)

Specified by:

setCorrelationStatus in interface MessageExchangeDAO

getCorrelationStatus

public java.lang.String getCorrelationStatus()

Specified by:

getCorrelationStatus in interface MessageExchangeDAO

getProcess

public ProcessDAO getProcess()

Specified by:

getProcess in interface MessageExchangeDAO

setProcess

public void setProcess(ProcessDAO process)

Specified by:

setProcess in interface MessageExchangeDAO

setInstance

public void setInstance(ProcessInstanceDAO dao)

Specified by:

setInstance in interface MessageExchangeDAO

getInstance

public ProcessInstanceDAO getInstance()

Specified by:

getInstance in interface MessageExchangeDAO

getDirection

public char getDirection()

Specified by:

getDirection in interface MessageExchangeDAO

getCallee

public javax.xml.namespace.QName getCallee()

Specified by:

getCallee in interface MessageExchangeDAO

setCallee

public void setCallee(javax.xml.namespace.QName callee)

Specified by:

setCallee in interface MessageExchangeDAO

getProperty

public java.lang.String getProperty(java.lang.String key)

Specified by:

getProperty in interface MessageExchangeDAO

setProperty

public void setProperty(java.lang.String key,
                        java.lang.String value)

Specified by:

setProperty in interface MessageExchangeDAO

setPartnerLink

public void setPartnerLink(PartnerLinkDAO plinkDAO)

Specified by:

setPartnerLink in interface MessageExchangeDAO

getPartnerLink

public PartnerLinkDAO getPartnerLink()

Specified by:

getPartnerLink in interface MessageExchangeDAO

getPropertyNames

public java.util.Set<java.lang.String> getPropertyNames()

Specified by:

getPropertyNames in interface MessageExchangeDAO

getPipedMessageExchangeId

public java.lang.String getPipedMessageExchangeId()

Specified by:

getPipedMessageExchangeId in interface MessageExchangeDAO

setPipedMessageExchangeId

public void setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)

Specified by:

setPipedMessageExchangeId in interface MessageExchangeDAO

getSubscriberCount

public int getSubscriberCount()

Specified by:

getSubscriberCount in interface MessageExchangeDAO

setSubscriberCount

public void setSubscriberCount(int subscriberCount)

Specified by:

setSubscriberCount in interface MessageExchangeDAO

incrementSubscriberCount

public void incrementSubscriberCount()

release

public void release(boolean doClean)

Specified by:

release in interface MessageExchangeDAO

releasePremieMessages

public void releasePremieMessages()

Specified by:

releasePremieMessages in interface MessageExchangeDAO

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

lockPremieMessages

public boolean lockPremieMessages()

Specified by:

lockPremieMessages in interface MessageExchangeDAO

getAttachments

public java.util.Collection<AttachmentDAO> getAttachments()

Specified by:

getAttachments in interface MessageExchangeDAO

setAttachments

public void setAttachments(java.util.Collection<AttachmentDAO> attachments)

Specified by:

setAttachments in interface MessageExchangeDAO