|
|||||||||
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(char direction)
|
Method Summary | |
---|---|
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 |
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 |
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)
|
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(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 getCorrelationId()
MessageExchangeDAO
getCorrelationId
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 java.lang.String 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()
getPropagateTransactionFlag
in interface MessageExchangeDAO
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 java.lang.String 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 setCorrelationId(java.lang.String correlationId)
MessageExchangeDAO
setCorrelationId
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(java.lang.String 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(java.lang.String 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 CorrelationKey getCorrelationKey()
getCorrelationKey
in interface CorrelatorMessageDAO
public void setCorrelationKey(CorrelationKey ckey)
setCorrelationKey
in interface CorrelatorMessageDAO
public void release(boolean doClean)
release
in interface MessageExchangeDAO
public void deleteMessages()
public CorrelatorDAOImpl getCorrelator()
public void setCorrelator(CorrelatorDAOImpl correlator)
public int getSubscriberCount()
getSubscriberCount
in interface MessageExchangeDAO
public void setSubscriberCount(int subscriberCount)
setSubscriberCount
in interface MessageExchangeDAO
public void incrementSubscriberCount()
public void release()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |