public class MessageExchangeDaoImpl extends HibernateDao implements MessageExchangeDAO
_hobj, _smDIR_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() |
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, updatepublic MessageExchangeDaoImpl(SessionManager sm, HMessageExchange mex)
public java.lang.String getMessageExchangeId()
MessageExchangeDAOgetMessageExchangeId in interface MessageExchangeDAOpublic MessageDAO getResponse()
MessageExchangeDAOgetResponse in interface MessageExchangeDAOpublic java.util.Date getCreateTime()
MessageExchangeDAOgetCreateTime in interface MessageExchangeDAOpublic void setCreateTime(java.util.Date createTime)
setCreateTime in interface MessageExchangeDAOpublic MessageDAO getRequest()
MessageExchangeDAOgetRequest in interface MessageExchangeDAOpublic java.lang.String getOperation()
MessageExchangeDAOgetOperation in interface MessageExchangeDAOpublic javax.xml.namespace.QName getPortType()
MessageExchangeDAOgetPortType in interface MessageExchangeDAOpublic void setPortType(javax.xml.namespace.QName porttype)
MessageExchangeDAOsetPortType in interface MessageExchangeDAOporttype - port typepublic void setStatus(java.lang.String status)
MessageExchangeDAOsetStatus in interface MessageExchangeDAOstatus - state to be setpublic java.lang.String getStatus()
MessageExchangeDAOgetStatus in interface MessageExchangeDAOpublic MessageDAO createMessage(javax.xml.namespace.QName type)
MessageExchangeDAOcreateMessage in interface MessageExchangeDAOtype - message typeMessageDAOpublic void setRequest(MessageDAO msg)
MessageExchangeDAOsetRequest in interface MessageExchangeDAOpublic void setResponse(MessageDAO msg)
MessageExchangeDAOsetResponse in interface MessageExchangeDAOpublic int getPartnerLinkModelId()
MessageExchangeDAOgetPartnerLinkModelId in interface MessageExchangeDAOpublic void setPartnerLinkModelId(int modelId)
MessageExchangeDAOsetPartnerLinkModelId in interface MessageExchangeDAOpublic java.lang.String getCorrelationId()
MessageExchangeDAOgetCorrelationId in interface MessageExchangeDAOpublic void setCorrelationId(java.lang.String clientKey)
MessageExchangeDAOsetCorrelationId in interface MessageExchangeDAOclientKey - identifierpublic void setPattern(java.lang.String pattern)
setPattern in interface MessageExchangeDAOpublic void setOperation(java.lang.String opname)
setOperation in interface MessageExchangeDAOpublic void setEPR(org.w3c.dom.Element source)
setEPR in interface MessageExchangeDAOpublic org.w3c.dom.Element getEPR()
getEPR in interface MessageExchangeDAOpublic void setCallbackEPR(org.w3c.dom.Element source)
public org.w3c.dom.Element getCallbackEPR()
public java.lang.String getPattern()
getPattern in interface MessageExchangeDAOpublic java.lang.String getChannel()
MessageExchangeDAOgetChannel in interface MessageExchangeDAOpublic void setChannel(java.lang.String channel)
MessageExchangeDAOsetChannel in interface MessageExchangeDAOchannel - response channelpublic boolean getPropagateTransactionFlag()
getPropagateTransactionFlag in interface MessageExchangeDAOpublic javax.xml.namespace.QName getFault()
getFault in interface MessageExchangeDAOpublic void setFault(javax.xml.namespace.QName faultType)
setFault in interface MessageExchangeDAOpublic java.lang.String getFaultExplanation()
getFaultExplanation in interface MessageExchangeDAOpublic void setFaultExplanation(java.lang.String explanation)
setFaultExplanation in interface MessageExchangeDAOpublic void setCorrelationStatus(java.lang.String cstatus)
setCorrelationStatus in interface MessageExchangeDAOpublic java.lang.String getCorrelationStatus()
getCorrelationStatus in interface MessageExchangeDAOpublic ProcessDAO getProcess()
MessageExchangeDAOgetProcess in interface MessageExchangeDAOpublic void setProcess(ProcessDAO process)
setProcess in interface MessageExchangeDAOpublic void setInstance(ProcessInstanceDAO instance)
setInstance in interface MessageExchangeDAOpublic ProcessInstanceDAO getInstance()
getInstance in interface MessageExchangeDAOpublic char getDirection()
MessageExchangeDAOgetDirection in interface MessageExchangeDAOpublic javax.xml.namespace.QName getCallee()
MessageExchangeDAOgetCallee in interface MessageExchangeDAOpublic void setCallee(javax.xml.namespace.QName callee)
MessageExchangeDAOsetCallee in interface MessageExchangeDAOpublic java.lang.String getProperty(java.lang.String key)
getProperty in interface MessageExchangeDAOpublic void setProperty(java.lang.String key,
java.lang.String value)
setProperty in interface MessageExchangeDAOpublic void setPartnerLink(PartnerLinkDAO plinkDAO)
setPartnerLink in interface MessageExchangeDAOpublic PartnerLinkDAO getPartnerLink()
getPartnerLink in interface MessageExchangeDAOpublic java.util.Set<java.lang.String> getPropertyNames()
getPropertyNames in interface MessageExchangeDAOpublic java.lang.String getPipedMessageExchangeId()
MessageExchangeDAOgetPipedMessageExchangeId in interface MessageExchangeDAOpublic void setPipedMessageExchangeId(java.lang.String mexId)
setPipedMessageExchangeId in interface MessageExchangeDAOpublic int getSubscriberCount()
getSubscriberCount in interface MessageExchangeDAOpublic void setSubscriberCount(int subscriberCount)
setSubscriberCount in interface MessageExchangeDAOpublic void release(boolean doClean)
release in interface MessageExchangeDAOpublic void releasePremieMessages()
MessageExchangeDAOreleasePremieMessages in interface MessageExchangeDAOpublic void incrementSubscriberCount()
public void deleteMessages()