org.apache.ode.bpel.engine

Class MyRoleMessageExchangeImpl

java.lang.Object

org.apache.ode.bpel.engine.MessageExchangeImpl

org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl

All Implemented Interfaces:

MessageExchange, MyRoleMessageExchange

Direct Known Subclasses:

BrokeredMyRoleMessageExchangeImpl

public class MyRoleMessageExchangeImpl
extends MessageExchangeImpl
implements MyRoleMessageExchange

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MyRoleMessageExchange

MyRoleMessageExchange.CorrelationStatus

Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MessageExchange

MessageExchange.FailureType, MessageExchange.MessageExchangePattern, MessageExchange.Status

Field Summary

Fields

Modifier and Type	Field and Description
protected BpelProcess	_process
protected static java.util.Map<java.lang.String,org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.ResponseCallback>	_waitingCallbacks

Fields inherited from class org.apache.ode.bpel.engine.MessageExchangeImpl

__msgs, _dao, _engine, _epr, _iid, _operation, _portType

Fields inherited from interface org.apache.ode.bpel.iapi.MessageExchange

PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_MYROLE_TRANSACTED, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID

Constructor Summary

Constructors

Constructor and Description
MyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, MessageExchangeDAO mexdao)

Method Summary

Modifier and Type	Method and Description
protected Message	cloneMessage(Message message) Return a deep clone of the given message
void	complete()
java.lang.String	getClientId()
MyRoleMessageExchange.CorrelationStatus	getCorrelationStatus()
javax.xml.namespace.QName	getServiceName()
java.util.concurrent.Future	invoke(Message request)
java.util.concurrent.Future	invoke(Message request, java.util.List<java.lang.String> attachmentIDs)
boolean	isAsynchronous()
void	release(boolean instanceSucceeded)
protected void	responseReceived()
void	setClientId(java.lang.String clientKey)
void	setCorrelationStatus(MyRoleMessageExchange.CorrelationStatus status)
java.lang.String	toString()

Methods inherited from class org.apache.ode.bpel.engine.MessageExchangeImpl

createMessage, getDAO, getEndpointReference, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperation, getOperationName, getPattern, getPortType, getProperty, getPropertyNames, getRequest, getResponse, getStatus, getSubscriberCount, isTransactionPropagated, release, setEndpointReference, setProperty, setSubscriberCount

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

Constructor Detail

MyRoleMessageExchangeImpl

public MyRoleMessageExchangeImpl(BpelProcess process,
                                 BpelEngineImpl engine,
                                 MessageExchangeDAO mexdao)

Method Detail

getCorrelationStatus

public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()

Specified by:

getCorrelationStatus in interface MyRoleMessageExchange

setCorrelationStatus

public void setCorrelationStatus(MyRoleMessageExchange.CorrelationStatus status)

invoke

public java.util.concurrent.Future invoke(Message request,
                                          java.util.List<java.lang.String> attachmentIDs)

Specified by:

invoke in interface MyRoleMessageExchange

invoke

public java.util.concurrent.Future invoke(Message request)

Specified by:

invoke in interface MyRoleMessageExchange

complete

public void complete()

Specified by:

complete in interface MyRoleMessageExchange

getServiceName

public javax.xml.namespace.QName getServiceName()

Specified by:

getServiceName in interface MyRoleMessageExchange

setClientId

public void setClientId(java.lang.String clientKey)

Specified by:

setClientId in interface MyRoleMessageExchange

getClientId

public java.lang.String getClientId()

Specified by:

getClientId in interface MyRoleMessageExchange

toString

public java.lang.String toString()

Overrides:

toString in class MessageExchangeImpl

isAsynchronous

public boolean isAsynchronous()

release

public void release(boolean instanceSucceeded)

Specified by:

release in interface MyRoleMessageExchange

cloneMessage

protected Message cloneMessage(Message message)

Return a deep clone of the given message

Parameters:

message -

Returns:

responseReceived

protected void responseReceived()

Overrides:

responseReceived in class MessageExchangeImpl