public class MessageExchangeDaoImpl extends HibernateDao implements MessageExchangeDAO
_hobj, _sm
DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE
Constructor and Description |
---|
MessageExchangeDaoImpl(SessionManager sm,
HMessageExchange mex) |
Modifier and Type | Method and Description |
---|---|
MessageDAO |
createMessage(javax.xml.namespace.QName type)
Create a new message associated with this message-exchange
|
void |
deleteMessages() |
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 source) |
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 channel)
Set the response channel.
|
void |
setCorrelationId(java.lang.String clientKey)
Set the correlation identifier/client id
|
void |
setCorrelationStatus(java.lang.String cstatus) |
void |
setCreateTime(java.util.Date createTime) |
void |
setEPR(org.w3c.dom.Element source) |
void |
setFault(javax.xml.namespace.QName faultType) |
void |
setFaultExplanation(java.lang.String explanation) |
void |
setInstance(ProcessInstanceDAO instance) |
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 pattern) |
void |
setPipedMessageExchangeId(java.lang.String mexId) |
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) |
deleteByColumn, deleteByIds, equals, getDHandle, getHibernateObj, getId, getSession, hashCode, update
public MessageExchangeDaoImpl(SessionManager sm, HMessageExchange mex)
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 createTime)
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 clientKey)
MessageExchangeDAO
setCorrelationId
in interface MessageExchangeDAO
clientKey
- identifierpublic void setPattern(java.lang.String pattern)
setPattern
in interface MessageExchangeDAO
public void setOperation(java.lang.String opname)
setOperation
in interface MessageExchangeDAO
public void setEPR(org.w3c.dom.Element source)
setEPR
in interface MessageExchangeDAO
public org.w3c.dom.Element getEPR()
getEPR
in interface MessageExchangeDAO
public void setCallbackEPR(org.w3c.dom.Element source)
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 channel)
MessageExchangeDAO
setChannel
in interface MessageExchangeDAO
channel
- 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 instance)
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 mexId)
setPipedMessageExchangeId
in interface MessageExchangeDAO
public int getSubscriberCount()
getSubscriberCount
in interface MessageExchangeDAO
public void setSubscriberCount(int subscriberCount)
setSubscriberCount
in interface MessageExchangeDAO
public void release(boolean doClean)
release
in interface MessageExchangeDAO
public void releasePremieMessages()
MessageExchangeDAO
releasePremieMessages
in interface MessageExchangeDAO
public void incrementSubscriberCount()
public void deleteMessages()
public boolean lockPremieMessages()
lockPremieMessages
in interface MessageExchangeDAO