org.apache.ode.bpel.engine
Class MyRoleMessageExchangeImpl

java.lang.Object
  extended by 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 Class Summary
 
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
 
Field Summary
protected static Messages __msgs
           
protected  org.apache.ode.bpel.dao.MessageExchangeDAO _dao
           
protected  BpelEngineImpl _engine
           
protected  org.apache.ode.bpel.iapi.EndpointReference _epr
           
protected  java.lang.Long _iid
          Process-Instance identifier.
protected  javax.wsdl.Operation _operation
           
protected  javax.wsdl.PortType _portType
           
protected  BpelProcess _process
           
protected static java.util.Map<java.lang.String,org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.ResponseCallback> _waitingCallbacks
           
 
Fields inherited from interface org.apache.ode.bpel.iapi.MessageExchange
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID
 
Constructor Summary
MyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, org.apache.ode.bpel.dao.MessageExchangeDAO mexdao)
           
 
Method Summary
protected  org.apache.ode.bpel.iapi.Message cloneMessage(org.apache.ode.bpel.iapi.Message message)
          Return a deep clone of the given message
 void complete()
           
 org.apache.ode.bpel.iapi.Message createMessage(javax.xml.namespace.QName msgType)
           
 java.lang.String getClientId()
           
 org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
           
 org.apache.ode.bpel.dao.MessageExchangeDAO getDAO()
           
 org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
           
 javax.xml.namespace.QName getFault()
           
 java.lang.String getFaultExplanation()
           
 org.apache.ode.bpel.iapi.Message getFaultResponse()
           
 java.lang.String getMessageExchangeId()
           
 org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern getMessageExchangePattern()
           
 javax.wsdl.Operation getOperation()
           
 java.lang.String getOperationName()
           
 org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern getPattern()
           
 javax.wsdl.PortType getPortType()
           
 java.lang.String getProperty(java.lang.String key)
           
 java.util.Set<java.lang.String> getPropertyNames()
           
 org.apache.ode.bpel.iapi.Message getRequest()
           
 org.apache.ode.bpel.iapi.Message getResponse()
           
 javax.xml.namespace.QName getServiceName()
           
 org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
           
 int getSubscriberCount()
           
 java.util.concurrent.Future invoke(org.apache.ode.bpel.iapi.Message request)
           
 boolean isAsynchronous()
           
 boolean isTransactionPropagated()
           
 void release()
           
 void release(boolean instanceSucceeded)
           
protected  void responseReceived()
           
 void setClientId(java.lang.String clientKey)
           
 void setCorrelationStatus(org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus status)
           
 void setEndpointReference(org.apache.ode.bpel.iapi.EndpointReference ref)
           
 void setProperty(java.lang.String key, java.lang.String value)
           
 void setSubscriberCount(int subscriberCount)
           
 java.lang.String toString()
           
 
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
 

Field Detail

_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
Constructor Detail

MyRoleMessageExchangeImpl

public MyRoleMessageExchangeImpl(BpelProcess process,
                                 BpelEngineImpl engine,
                                 org.apache.ode.bpel.dao.MessageExchangeDAO mexdao)
Method Detail

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