|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.dao.jpa.OpenJPADAO
org.apache.ode.dao.jpa.MessageExchangeDAOImpl
public class MessageExchangeDAOImpl
Field Summary | |
---|---|
static java.lang.String |
DELETE_MEXS_BY_PROCESS
|
static java.lang.String |
SELECT_MEX_IDS_BY_PROCESS
|
Fields inherited from interface org.apache.ode.bpel.dao.MessageExchangeDAO |
---|
DIR_BPEL_INVOKES_PARTNERROLE, DIR_PARTNER_INVOKES_MYROLE |
Constructor Summary | |
---|---|
MessageExchangeDAOImpl()
|
|
MessageExchangeDAOImpl(java.lang.String mexId,
char direction)
|
Method Summary | |
---|---|
void |
addCorrelationKey(CorrelationKey correlationKey)
|
MessageDAO |
createMessage(javax.xml.namespace.QName type)
Create a new message associated with this message-exchange |
void |
deleteMessages()
|
MessageExchange.AckType |
getAckType()
|
javax.xml.namespace.QName |
getCallee()
Get the "callee"--the id of the service being invoked in a myRole exchange. |
java.lang.String |
getChannel()
Get the response channel. |
java.util.Collection<CorrelationKey> |
getCorrelationKeys()
|
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()
|
MessageExchange.FailureType |
getFailureType()
|
javax.xml.namespace.QName |
getFault()
|
java.lang.String |
getFaultExplanation()
|
ProcessInstanceDAO |
getInstance()
|
InvocationStyle |
getInvocationStyle()
Get the invocation style. |
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 |
getPartnersKey()
Get the the partner's identifier for this message exchange. |
MessageExchange.MessageExchangePattern |
getPattern()
|
java.lang.String |
getPipedMessageExchangeId()
Gets the message exchange that has been piped with this one in a process to process interaction. |
javax.xml.namespace.QName |
getPipedPID()
|
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) |
MessageExchange.Status |
getStatus()
Get state of last message sent/received. |
long |
getTimeout()
|
void |
release(boolean doClean)
|
void |
setAckType(MessageExchange.AckType ackType)
|
void |
setCallee(javax.xml.namespace.QName callee)
Set the "callee"--the id of the service being invoked in a myRole exchange. |
void |
setChannel(java.lang.String channel)
Set the response channel. |
void |
setCorrelationStatus(java.lang.String cstatus)
|
void |
setCorrelator(CorrelatorDAOImpl correlator)
|
void |
setEPR(org.w3c.dom.Element epr)
|
void |
setFailureType(MessageExchange.FailureType failureType)
|
void |
setFault(javax.xml.namespace.QName faultType)
|
void |
setFaultExplanation(java.lang.String explanation)
|
void |
setInstance(ProcessInstanceDAO dao)
|
void |
setInvocationStyle(InvocationStyle invocationStyle)
Set the invocation style. |
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 |
setPartnersKey(java.lang.String correlationId)
Set the correlation identifier/client id |
void |
setPattern(MessageExchange.MessageExchangePattern pattern)
|
void |
setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
|
void |
setPipedPID(javax.xml.namespace.QName pipedPid)
|
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(MessageExchange.Status status)
Set state of last message sent/received. |
void |
setTimeout(long timeout)
|
Methods inherited from class org.apache.ode.dao.jpa.OpenJPADAO |
---|
batchUpdateByIds, getConn, getEM, getSingleResult |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String DELETE_MEXS_BY_PROCESS
public static final java.lang.String SELECT_MEX_IDS_BY_PROCESS
Constructor Detail |
---|
public MessageExchangeDAOImpl()
public MessageExchangeDAOImpl(java.lang.String mexId, char direction)
Method Detail |
---|
public MessageDAO createMessage(javax.xml.namespace.QName type)
MessageExchangeDAO
createMessage
in interface MessageExchangeDAO
type
- message type
MessageDAO
public javax.xml.namespace.QName getCallee()
MessageExchangeDAO
getCallee
in interface MessageExchangeDAO
public java.lang.String getChannel()
MessageExchangeDAO
getChannel
in interface MessageExchangeDAO
public java.lang.String getPartnersKey()
MessageExchangeDAO
getPartnersKey
in interface MessageExchangeDAO
public java.lang.String getCorrelationStatus()
getCorrelationStatus
in interface MessageExchangeDAO
public java.util.Date getCreateTime()
MessageExchangeDAO
getCreateTime
in interface MessageExchangeDAO
public char getDirection()
MessageExchangeDAO
getDirection
in interface MessageExchangeDAO
public org.w3c.dom.Element getEPR()
getEPR
in interface MessageExchangeDAO
public javax.xml.namespace.QName getFault()
getFault
in interface MessageExchangeDAO
public java.lang.String getFaultExplanation()
getFaultExplanation
in interface MessageExchangeDAO
public ProcessInstanceDAO getInstance()
getInstance
in interface MessageExchangeDAO
public java.lang.String getMessageExchangeId()
MessageExchangeDAO
getMessageExchangeId
in interface MessageExchangeDAO
public java.lang.String getOperation()
MessageExchangeDAO
getOperation
in interface MessageExchangeDAO
public PartnerLinkDAO getPartnerLink()
getPartnerLink
in interface MessageExchangeDAO
public int getPartnerLinkModelId()
MessageExchangeDAO
getPartnerLinkModelId
in interface MessageExchangeDAO
public MessageExchange.MessageExchangePattern getPattern()
getPattern
in interface MessageExchangeDAO
public javax.xml.namespace.QName getPortType()
MessageExchangeDAO
getPortType
in interface MessageExchangeDAO
public ProcessDAO getProcess()
MessageExchangeDAO
getProcess
in interface MessageExchangeDAO
public boolean getPropagateTransactionFlag()
public java.lang.String getProperty(java.lang.String key)
getProperty
in interface MessageExchangeDAO
public java.util.Set<java.lang.String> getPropertyNames()
getPropertyNames
in interface MessageExchangeDAO
public MessageDAO getRequest()
MessageExchangeDAO
getRequest
in interface MessageExchangeDAO
public MessageDAO getResponse()
MessageExchangeDAO
getResponse
in interface MessageExchangeDAO
public MessageExchange.Status getStatus()
MessageExchangeDAO
getStatus
in interface MessageExchangeDAO
public void setCallee(javax.xml.namespace.QName callee)
MessageExchangeDAO
setCallee
in interface MessageExchangeDAO
public void setChannel(java.lang.String channel)
MessageExchangeDAO
setChannel
in interface MessageExchangeDAO
channel
- response channelpublic void setPartnersKey(java.lang.String correlationId)
MessageExchangeDAO
setPartnersKey
in interface MessageExchangeDAO
correlationId
- identifierpublic void setCorrelationStatus(java.lang.String cstatus)
setCorrelationStatus
in interface MessageExchangeDAO
public void setEPR(org.w3c.dom.Element epr)
setEPR
in interface MessageExchangeDAO
public void setFault(javax.xml.namespace.QName faultType)
setFault
in interface MessageExchangeDAO
public void setFaultExplanation(java.lang.String explanation)
setFaultExplanation
in interface MessageExchangeDAO
public void setInstance(ProcessInstanceDAO dao)
setInstance
in interface MessageExchangeDAO
public void setOperation(java.lang.String opname)
setOperation
in interface MessageExchangeDAO
public void setPartnerLink(PartnerLinkDAO plinkDAO)
setPartnerLink
in interface MessageExchangeDAO
public void setPartnerLinkModelId(int modelId)
MessageExchangeDAO
setPartnerLinkModelId
in interface MessageExchangeDAO
public void setPattern(MessageExchange.MessageExchangePattern pattern)
setPattern
in interface MessageExchangeDAO
public void setPortType(javax.xml.namespace.QName porttype)
MessageExchangeDAO
setPortType
in interface MessageExchangeDAO
porttype
- port typepublic void setProcess(ProcessDAO process)
setProcess
in interface MessageExchangeDAO
public void setProperty(java.lang.String key, java.lang.String value)
setProperty
in interface MessageExchangeDAO
public void setRequest(MessageDAO msg)
MessageExchangeDAO
setRequest
in interface MessageExchangeDAO
public void setResponse(MessageDAO msg)
MessageExchangeDAO
setResponse
in interface MessageExchangeDAO
public void setStatus(MessageExchange.Status status)
MessageExchangeDAO
setStatus
in interface MessageExchangeDAO
status
- state to be setpublic java.lang.String getPipedMessageExchangeId()
MessageExchangeDAO
getPipedMessageExchangeId
in interface MessageExchangeDAO
public void setPipedMessageExchangeId(java.lang.String pipedMessageExchangeId)
setPipedMessageExchangeId
in interface MessageExchangeDAO
public void addCorrelationKey(CorrelationKey correlationKey)
public java.util.Collection<CorrelationKey> getCorrelationKeys()
public void release(boolean doClean)
release
in interface MessageExchangeDAO
public void deleteMessages()
public CorrelatorDAOImpl getCorrelator()
public void setCorrelator(CorrelatorDAOImpl correlator)
public InvocationStyle getInvocationStyle()
MessageExchangeDAO
getInvocationStyle
in interface MessageExchangeDAO
public long getTimeout()
getTimeout
in interface MessageExchangeDAO
public void setFailureType(MessageExchange.FailureType failureType)
setFailureType
in interface MessageExchangeDAO
public MessageExchange.FailureType getFailureType()
getFailureType
in interface MessageExchangeDAO
public void setInvocationStyle(InvocationStyle invocationStyle)
MessageExchangeDAO
setInvocationStyle
in interface MessageExchangeDAO
public void setTimeout(long timeout)
setTimeout
in interface MessageExchangeDAO
public MessageExchange.AckType getAckType()
getAckType
in interface MessageExchangeDAO
public void setAckType(MessageExchange.AckType ackType)
setAckType
in interface MessageExchangeDAO
public javax.xml.namespace.QName getPipedPID()
getPipedPID
in interface MessageExchangeDAO
public void setPipedPID(javax.xml.namespace.QName pipedPid)
setPipedPID
in interface MessageExchangeDAO
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |