public class MessageExchangeDAOImpl extends OpenJPADAO implements MessageExchangeDAO, CorrelatorMessageDAO
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DELETE_MEXS_BY_PROCESS |
static java.lang.String |
SELECT_MEX_IDS_BY_PROCESS |
DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE| Constructor and Description |
|---|
MessageExchangeDAOImpl() |
MessageExchangeDAOImpl(char direction) |
| Modifier and Type | Method and Description |
|---|---|
MessageDAO |
createMessage(javax.xml.namespace.QName type)
Create a new message associated with this message-exchange
|
void |
deleteMessages() |
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
|
CorrelationKey |
getCorrelationKey() |
java.lang.String |
getCorrelationStatus() |
CorrelatorDAOImpl |
getCorrelator() |
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() |
void |
release(boolean doClean) |
void |
releasePremieMessages()
Deletes messages that arrived before the route is setup
|
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 correlationId)
Set the correlation identifier/client id
|
void |
setCorrelationKey(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(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 pattern) |
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) |
batchUpdateByIds, getConn, getEM, getSingleResultpublic static final java.lang.String DELETE_MEXS_BY_PROCESS
public static final java.lang.String SELECT_MEX_IDS_BY_PROCESS
public MessageExchangeDAOImpl()
public MessageExchangeDAOImpl(char direction)
public MessageDAO createMessage(javax.xml.namespace.QName type)
MessageExchangeDAOcreateMessage in interface MessageExchangeDAOtype - message typeMessageDAOpublic javax.xml.namespace.QName getCallee()
MessageExchangeDAOgetCallee in interface MessageExchangeDAOpublic java.lang.String getChannel()
MessageExchangeDAOgetChannel in interface MessageExchangeDAOpublic java.lang.String getCorrelationId()
MessageExchangeDAOgetCorrelationId in interface MessageExchangeDAOpublic java.lang.String getCorrelationStatus()
getCorrelationStatus in interface MessageExchangeDAOpublic java.util.Date getCreateTime()
MessageExchangeDAOgetCreateTime in interface MessageExchangeDAOpublic char getDirection()
MessageExchangeDAOgetDirection in interface MessageExchangeDAOpublic org.w3c.dom.Element getEPR()
getEPR in interface MessageExchangeDAOpublic javax.xml.namespace.QName getFault()
getFault in interface MessageExchangeDAOpublic java.lang.String getFaultExplanation()
getFaultExplanation in interface MessageExchangeDAOpublic ProcessInstanceDAO getInstance()
getInstance in interface MessageExchangeDAOpublic java.lang.String getMessageExchangeId()
MessageExchangeDAOgetMessageExchangeId in interface MessageExchangeDAOpublic java.lang.String getOperation()
MessageExchangeDAOgetOperation in interface MessageExchangeDAOpublic PartnerLinkDAO getPartnerLink()
getPartnerLink in interface MessageExchangeDAOpublic int getPartnerLinkModelId()
MessageExchangeDAOgetPartnerLinkModelId in interface MessageExchangeDAOpublic java.lang.String getPattern()
getPattern in interface MessageExchangeDAOpublic javax.xml.namespace.QName getPortType()
MessageExchangeDAOgetPortType in interface MessageExchangeDAOpublic ProcessDAO getProcess()
MessageExchangeDAOgetProcess in interface MessageExchangeDAOpublic boolean getPropagateTransactionFlag()
getPropagateTransactionFlag in interface MessageExchangeDAOpublic java.lang.String getProperty(java.lang.String key)
getProperty in interface MessageExchangeDAOpublic java.util.Set<java.lang.String> getPropertyNames()
getPropertyNames in interface MessageExchangeDAOpublic MessageDAO getRequest()
MessageExchangeDAOgetRequest in interface MessageExchangeDAOpublic MessageDAO getResponse()
MessageExchangeDAOgetResponse in interface MessageExchangeDAOpublic java.lang.String getStatus()
MessageExchangeDAOgetStatus in interface MessageExchangeDAOpublic void setCallee(javax.xml.namespace.QName callee)
MessageExchangeDAOsetCallee in interface MessageExchangeDAOpublic void setChannel(java.lang.String channel)
MessageExchangeDAOsetChannel in interface MessageExchangeDAOchannel - response channelpublic void setCorrelationId(java.lang.String correlationId)
MessageExchangeDAOsetCorrelationId in interface MessageExchangeDAOcorrelationId - identifierpublic void setCorrelationStatus(java.lang.String cstatus)
setCorrelationStatus in interface MessageExchangeDAOpublic void setEPR(org.w3c.dom.Element epr)
setEPR in interface MessageExchangeDAOpublic void setFault(javax.xml.namespace.QName faultType)
setFault in interface MessageExchangeDAOpublic void setFaultExplanation(java.lang.String explanation)
setFaultExplanation in interface MessageExchangeDAOpublic void setInstance(ProcessInstanceDAO dao)
setInstance in interface MessageExchangeDAOpublic void setOperation(java.lang.String opname)
setOperation in interface MessageExchangeDAOpublic void setPartnerLink(PartnerLinkDAO plinkDAO)
setPartnerLink in interface MessageExchangeDAOpublic void setPartnerLinkModelId(int modelId)
MessageExchangeDAOsetPartnerLinkModelId in interface MessageExchangeDAOpublic void setPattern(java.lang.String pattern)
setPattern in interface MessageExchangeDAOpublic void setPortType(javax.xml.namespace.QName porttype)
MessageExchangeDAOsetPortType in interface MessageExchangeDAOporttype - port typepublic void setProcess(ProcessDAO process)
setProcess in interface MessageExchangeDAOpublic void setProperty(java.lang.String key,
java.lang.String value)
setProperty in interface MessageExchangeDAOpublic void setRequest(MessageDAO msg)
MessageExchangeDAOsetRequest in interface MessageExchangeDAOpublic void setResponse(MessageDAO msg)
MessageExchangeDAOsetResponse in interface MessageExchangeDAOpublic void setStatus(java.lang.String status)
MessageExchangeDAOsetStatus in interface MessageExchangeDAOstatus - state to be setpublic java.lang.String getPipedMessageExchangeId()
MessageExchangeDAOgetPipedMessageExchangeId in interface MessageExchangeDAOpublic void setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
setPipedMessageExchangeId in interface MessageExchangeDAOpublic CorrelationKey getCorrelationKey()
getCorrelationKey in interface CorrelatorMessageDAOpublic void setCorrelationKey(CorrelationKey ckey)
setCorrelationKey in interface CorrelatorMessageDAOpublic void release(boolean doClean)
release in interface MessageExchangeDAOpublic void releasePremieMessages()
MessageExchangeDAOreleasePremieMessages in interface MessageExchangeDAOpublic void deleteMessages()
public CorrelatorDAOImpl getCorrelator()
public void setCorrelator(CorrelatorDAOImpl correlator)
public int getSubscriberCount()
getSubscriberCount in interface MessageExchangeDAOpublic void setSubscriberCount(int subscriberCount)
setSubscriberCount in interface MessageExchangeDAOpublic void incrementSubscriberCount()
public void release()
public void setCreateTime(java.util.Date createTime)
setCreateTime in interface MessageExchangeDAO