org.apache.ode.bpel.engine
Class MyRoleMessageExchangeImpl
java.lang.Object
org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.iapi.MessageExchange, org.apache.ode.bpel.iapi.MyRoleMessageExchange
- Direct Known Subclasses:
- BrokeredMyRoleMessageExchangeImpl
public class MyRoleMessageExchangeImpl
- extends java.lang.Object
- implements org.apache.ode.bpel.iapi.MyRoleMessageExchange
| Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MyRoleMessageExchange |
org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus |
| Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
org.apache.ode.bpel.iapi.MessageExchange.FailureType, org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern, org.apache.ode.bpel.iapi.MessageExchange.Status |
| Fields inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
createMessage, getEndpointReference, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperation, getOperationName, getPortType, getProperty, getPropertyNames, getRequest, getResponse, getStatus, isTransactionPropagated, release, setProperty |
_process
protected BpelProcess _process
_waitingCallbacks
protected static java.util.Map<java.lang.String,org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.ResponseCallback> _waitingCallbacks
__msgs
protected static final Messages __msgs
_iid
protected java.lang.Long _iid
- Process-Instance identifier.
_portType
protected javax.wsdl.PortType _portType
_operation
protected javax.wsdl.Operation _operation
_engine
protected final BpelEngineImpl _engine
_epr
protected org.apache.ode.bpel.iapi.EndpointReference _epr
_dao
protected org.apache.ode.bpel.dao.MessageExchangeDAO _dao
MyRoleMessageExchangeImpl
public MyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
org.apache.ode.bpel.dao.MessageExchangeDAO mexdao)
getCorrelationStatus
public org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
- Specified by:
getCorrelationStatus in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
setCorrelationStatus
public void setCorrelationStatus(org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus status)
invoke
public java.util.concurrent.Future invoke(org.apache.ode.bpel.iapi.Message request)
- Specified by:
invoke in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
complete
public void complete()
- Specified by:
complete in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
getServiceName
public javax.xml.namespace.QName getServiceName()
- Specified by:
getServiceName in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
setClientId
public void setClientId(java.lang.String clientKey)
- Specified by:
setClientId in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
getClientId
public java.lang.String getClientId()
- Specified by:
getClientId in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
toString
public java.lang.String toString()
isAsynchronous
public boolean isAsynchronous()
release
public void release(boolean instanceSucceeded)
- Specified by:
release in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
cloneMessage
protected org.apache.ode.bpel.iapi.Message cloneMessage(org.apache.ode.bpel.iapi.Message message)
- Return a deep clone of the given message
- Parameters:
message -
- Returns:
responseReceived
protected void responseReceived()
getMessageExchangeId
public java.lang.String getMessageExchangeId()
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
getMessageExchangeId in interface org.apache.ode.bpel.iapi.MessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
getOperationName
public java.lang.String getOperationName()
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
getOperationName in interface org.apache.ode.bpel.iapi.MessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
getMessageExchangePattern
public org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern getMessageExchangePattern()
- Specified by:
getMessageExchangePattern in interface org.apache.ode.bpel.iapi.MessageExchange
isTransactionPropagated
public boolean isTransactionPropagated()
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
isTransactionPropagated in interface org.apache.ode.bpel.iapi.MessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
getResponse
public org.apache.ode.bpel.iapi.Message getResponse()
- Specified by:
getResponse in interface org.apache.ode.bpel.iapi.MessageExchange
getFault
public javax.xml.namespace.QName getFault()
- Specified by:
getFault in interface org.apache.ode.bpel.iapi.MessageExchange
getFaultResponse
public org.apache.ode.bpel.iapi.Message getFaultResponse()
- Specified by:
getFaultResponse in interface org.apache.ode.bpel.iapi.MessageExchange
getFaultExplanation
public java.lang.String getFaultExplanation()
- Specified by:
getFaultExplanation in interface org.apache.ode.bpel.iapi.MessageExchange
getPattern
public org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern getPattern()
getStatus
public org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
- Specified by:
getStatus in interface org.apache.ode.bpel.iapi.MessageExchange
getRequest
public org.apache.ode.bpel.iapi.Message getRequest()
- Specified by:
getRequest in interface org.apache.ode.bpel.iapi.MessageExchange
getOperation
public javax.wsdl.Operation getOperation()
- Specified by:
getOperation in interface org.apache.ode.bpel.iapi.MessageExchange
getPortType
public javax.wsdl.PortType getPortType()
- Specified by:
getPortType in interface org.apache.ode.bpel.iapi.MessageExchange
getDAO
public org.apache.ode.bpel.dao.MessageExchangeDAO getDAO()
createMessage
public org.apache.ode.bpel.iapi.Message createMessage(javax.xml.namespace.QName msgType)
- Specified by:
createMessage in interface org.apache.ode.bpel.iapi.MessageExchange
setEndpointReference
public void setEndpointReference(org.apache.ode.bpel.iapi.EndpointReference ref)
getEndpointReference
public org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
getEndpointReference in interface org.apache.ode.bpel.iapi.MessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
getProperty
public java.lang.String getProperty(java.lang.String key)
- Specified by:
getProperty in interface org.apache.ode.bpel.iapi.MessageExchange
setProperty
public void setProperty(java.lang.String key,
java.lang.String value)
- Specified by:
setProperty in interface org.apache.ode.bpel.iapi.MessageExchange
getPropertyNames
public java.util.Set<java.lang.String> getPropertyNames()
- Specified by:
getPropertyNames in interface org.apache.ode.bpel.iapi.MessageExchange
getSubscriberCount
public int getSubscriberCount()
setSubscriberCount
public void setSubscriberCount(int subscriberCount)
release
public void release()
- Specified by:
release in interface org.apache.ode.bpel.iapi.MessageExchange