public class MessageExchangeDAOImpl extends java.lang.Object implements MessageExchangeDAO
DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE
Constructor and Description |
---|
MessageExchangeDAOImpl(char direction,
java.lang.String messageEchangeId) |
Modifier and Type | Method and Description |
---|---|
MessageDAO |
createMessage(javax.xml.namespace.QName type)
Create a new message associated with this message-exchange
|
org.w3c.dom.Element |
getCallbackEPR() |
javax.xml.namespace.QName |
getCallee()
Get the "callee"--the id of the process being invoked in a myRole
exchange.
|
java.lang.String |
getChannel()
Get the response channel.
|
java.lang.String |
getCorrelationId()
Get the correlation identifier/client id
|
java.lang.String |
getCorrelationStatus() |
java.util.Date |
getCreateTime()
Creation time of the message exchange
|
char |
getDirection()
Get the direction of the message exchange.
|
org.w3c.dom.Element |
getEPR() |
javax.xml.namespace.QName |
getFault() |
java.lang.String |
getFaultExplanation() |
ProcessInstanceDAO |
getInstance() |
java.lang.String |
getMessageExchangeId()
Instance id of the message exchange.
|
java.lang.String |
getOperation()
Get the operation name of this message exchange.
|
PartnerLinkDAO |
getPartnerLink() |
int |
getPartnerLinkModelId()
Get the model id for the partner link to which this message exchange
relates.
|
java.lang.String |
getPattern() |
java.lang.String |
getPipedMessageExchangeId()
Gets the mex id for the message exchange that has been piped with
this one in a process to process interaction.
|
javax.xml.namespace.QName |
getPortType()
The qualified name of the WSDL port type.
|
ProcessDAO |
getProcess()
Get the process associate with this message exchange.
|
boolean |
getPropagateTransactionFlag() |
java.lang.String |
getProperty(java.lang.String key) |
java.util.Set<java.lang.String> |
getPropertyNames() |
MessageDAO |
getRequest()
Get the input message.
|
MessageDAO |
getResponse()
Get output message (could be fault message)
|
java.lang.String |
getStatus()
Get state of last message sent/received.
|
int |
getSubscriberCount() |
void |
incrementSubscriberCount() |
boolean |
lockPremieMessages() |
void |
release(boolean doClean) |
void |
releasePremieMessages()
Deletes messages that arrived before the route is setup
|
void |
setCallbackEPR(org.w3c.dom.Element epr) |
void |
setCallee(javax.xml.namespace.QName callee)
Set the "callee"--the id of the process being invoked in a myRole
exchange.
|
void |
setChannel(java.lang.String string)
Set the response channel.
|
void |
setCorrelationId(java.lang.String correlationId)
Set the correlation identifier/client id
|
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)
Set the model id for the partner link to which this message exchange
relates
|
void |
setPattern(java.lang.String string) |
void |
setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId) |
void |
setPortType(javax.xml.namespace.QName porttype)
Set the port type.
|
void |
setProcess(ProcessDAO process) |
void |
setProperty(java.lang.String key,
java.lang.String value) |
void |
setRequest(MessageDAO msg)
Creates an input message DAO.
|
void |
setResponse(MessageDAO msg)
Creates an output message DAO.
|
void |
setStatus(java.lang.String status)
Set state of last message sent/received.
|
void |
setSubscriberCount(int subscriberCount) |
java.lang.String |
toString() |
public MessageExchangeDAOImpl(char direction, java.lang.String messageEchangeId)
public java.lang.String getMessageExchangeId()
MessageExchangeDAO
getMessageExchangeId
in interface MessageExchangeDAO
public MessageDAO getResponse()
MessageExchangeDAO
getResponse
in interface MessageExchangeDAO
public java.util.Date getCreateTime()
MessageExchangeDAO
getCreateTime
in interface MessageExchangeDAO
public void setCreateTime(java.util.Date d)
setCreateTime
in interface MessageExchangeDAO
public MessageDAO getRequest()
MessageExchangeDAO
getRequest
in interface MessageExchangeDAO
public java.lang.String getOperation()
MessageExchangeDAO
getOperation
in interface MessageExchangeDAO
public javax.xml.namespace.QName getPortType()
MessageExchangeDAO
getPortType
in interface MessageExchangeDAO
public void setPortType(javax.xml.namespace.QName porttype)
MessageExchangeDAO
setPortType
in interface MessageExchangeDAO
porttype
- port typepublic void setStatus(java.lang.String status)
MessageExchangeDAO
setStatus
in interface MessageExchangeDAO
status
- state to be setpublic java.lang.String getStatus()
MessageExchangeDAO
getStatus
in interface MessageExchangeDAO
public MessageDAO createMessage(javax.xml.namespace.QName type)
MessageExchangeDAO
createMessage
in interface MessageExchangeDAO
type
- message typeMessageDAO
public void setRequest(MessageDAO msg)
MessageExchangeDAO
setRequest
in interface MessageExchangeDAO
public void setResponse(MessageDAO msg)
MessageExchangeDAO
setResponse
in interface MessageExchangeDAO
public int getPartnerLinkModelId()
MessageExchangeDAO
getPartnerLinkModelId
in interface MessageExchangeDAO
public void setPartnerLinkModelId(int modelId)
MessageExchangeDAO
setPartnerLinkModelId
in interface MessageExchangeDAO
public java.lang.String getCorrelationId()
MessageExchangeDAO
getCorrelationId
in interface MessageExchangeDAO
public void setCorrelationId(java.lang.String correlationId)
MessageExchangeDAO
setCorrelationId
in interface MessageExchangeDAO
correlationId
- identifierpublic void setPattern(java.lang.String string)
setPattern
in interface MessageExchangeDAO
public void setOperation(java.lang.String opname)
setOperation
in interface MessageExchangeDAO
public void setEPR(org.w3c.dom.Element epr)
setEPR
in interface MessageExchangeDAO
public org.w3c.dom.Element getEPR()
getEPR
in interface MessageExchangeDAO
public void setCallbackEPR(org.w3c.dom.Element epr)
public org.w3c.dom.Element getCallbackEPR()
public java.lang.String getPattern()
getPattern
in interface MessageExchangeDAO
public java.lang.String getChannel()
MessageExchangeDAO
getChannel
in interface MessageExchangeDAO
public void setChannel(java.lang.String string)
MessageExchangeDAO
setChannel
in interface MessageExchangeDAO
string
- response channelpublic boolean getPropagateTransactionFlag()
getPropagateTransactionFlag
in interface MessageExchangeDAO
public javax.xml.namespace.QName getFault()
getFault
in interface MessageExchangeDAO
public void setFault(javax.xml.namespace.QName faultType)
setFault
in interface MessageExchangeDAO
public java.lang.String getFaultExplanation()
getFaultExplanation
in interface MessageExchangeDAO
public void setFaultExplanation(java.lang.String explanation)
setFaultExplanation
in interface MessageExchangeDAO
public void setCorrelationStatus(java.lang.String cstatus)
setCorrelationStatus
in interface MessageExchangeDAO
public java.lang.String getCorrelationStatus()
getCorrelationStatus
in interface MessageExchangeDAO
public ProcessDAO getProcess()
MessageExchangeDAO
getProcess
in interface MessageExchangeDAO
public void setProcess(ProcessDAO process)
setProcess
in interface MessageExchangeDAO
public void setInstance(ProcessInstanceDAO dao)
setInstance
in interface MessageExchangeDAO
public ProcessInstanceDAO getInstance()
getInstance
in interface MessageExchangeDAO
public char getDirection()
MessageExchangeDAO
getDirection
in interface MessageExchangeDAO
public javax.xml.namespace.QName getCallee()
MessageExchangeDAO
getCallee
in interface MessageExchangeDAO
public void setCallee(javax.xml.namespace.QName callee)
MessageExchangeDAO
setCallee
in interface MessageExchangeDAO
public java.lang.String getProperty(java.lang.String key)
getProperty
in interface MessageExchangeDAO
public void setProperty(java.lang.String key, java.lang.String value)
setProperty
in interface MessageExchangeDAO
public void setPartnerLink(PartnerLinkDAO plinkDAO)
setPartnerLink
in interface MessageExchangeDAO
public PartnerLinkDAO getPartnerLink()
getPartnerLink
in interface MessageExchangeDAO
public java.util.Set<java.lang.String> getPropertyNames()
getPropertyNames
in interface MessageExchangeDAO
public java.lang.String getPipedMessageExchangeId()
MessageExchangeDAO
getPipedMessageExchangeId
in interface MessageExchangeDAO
public void setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
setPipedMessageExchangeId
in interface MessageExchangeDAO
public int getSubscriberCount()
getSubscriberCount
in interface MessageExchangeDAO
public void setSubscriberCount(int subscriberCount)
setSubscriberCount
in interface MessageExchangeDAO
public void incrementSubscriberCount()
public void release(boolean doClean)
release
in interface MessageExchangeDAO
public void releasePremieMessages()
MessageExchangeDAO
releasePremieMessages
in interface MessageExchangeDAO
public java.lang.String toString()
toString
in class java.lang.Object
public boolean lockPremieMessages()
lockPremieMessages
in interface MessageExchangeDAO