org.apache.ode.bpel.engine

Class MessageExchangeImpl

java.lang.Object

org.apache.ode.bpel.engine.MessageExchangeImpl

All Implemented Interfaces:

MessageExchange

Direct Known Subclasses:

MyRoleMessageExchangeImpl, PartnerRoleMessageExchangeImpl

public abstract class MessageExchangeImpl
extends java.lang.Object
implements MessageExchange

Nested Class Summary

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 static Messages	__msgs
protected MessageExchangeDAO	_dao
protected BpelEngineImpl	_engine
protected EndpointReference	_epr
protected java.lang.Long	_iid Process-Instance identifier.
protected javax.wsdl.Operation	_operation
protected javax.wsdl.PortType	_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
MessageExchangeImpl(BpelEngineImpl engine, MessageExchangeDAO dao)

Method Summary

Modifier and Type	Method and Description
Message	createMessage(javax.xml.namespace.QName msgType)
MessageExchangeDAO	getDAO()
EndpointReference	getEndpointReference()
javax.xml.namespace.QName	getFault()
java.lang.String	getFaultExplanation()
Message	getFaultResponse()
java.lang.String	getMessageExchangeId()
MessageExchange.MessageExchangePattern	getMessageExchangePattern()
javax.wsdl.Operation	getOperation()
java.lang.String	getOperationName()
MessageExchange.MessageExchangePattern	getPattern()
javax.wsdl.PortType	getPortType()
java.lang.String	getProperty(java.lang.String key)
java.util.Set<java.lang.String>	getPropertyNames()
Message	getRequest()
Message	getResponse()
MessageExchange.Status	getStatus()
int	getSubscriberCount()
boolean	isTransactionPropagated()
void	release()
protected void	responseReceived()
void	setEndpointReference(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

Field Detail

__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 EndpointReference _epr

_dao

protected MessageExchangeDAO _dao

Constructor Detail

MessageExchangeImpl

public MessageExchangeImpl(BpelEngineImpl engine,
                           MessageExchangeDAO dao)

Method Detail

getMessageExchangeId

public java.lang.String getMessageExchangeId()
                                      throws BpelEngineException

Specified by:

getMessageExchangeId in interface MessageExchange

Throws:

BpelEngineException

getOperationName

public java.lang.String getOperationName()
                                  throws BpelEngineException

Specified by:

getOperationName in interface MessageExchange

Throws:

BpelEngineException

getMessageExchangePattern

public MessageExchange.MessageExchangePattern getMessageExchangePattern()

Specified by:

getMessageExchangePattern in interface MessageExchange

isTransactionPropagated

public boolean isTransactionPropagated()
                                throws BpelEngineException

Specified by:

isTransactionPropagated in interface MessageExchange

Throws:

BpelEngineException

getResponse

public Message getResponse()

Specified by:

getResponse in interface MessageExchange

getFault

public javax.xml.namespace.QName getFault()

Specified by:

getFault in interface MessageExchange

getFaultResponse

public Message getFaultResponse()

Specified by:

getFaultResponse in interface MessageExchange

getFaultExplanation

public java.lang.String getFaultExplanation()

Specified by:

getFaultExplanation in interface MessageExchange

getPattern

public MessageExchange.MessageExchangePattern getPattern()

getStatus

public MessageExchange.Status getStatus()

Specified by:

getStatus in interface MessageExchange

getRequest

public Message getRequest()

Specified by:

getRequest in interface MessageExchange

getOperation

public javax.wsdl.Operation getOperation()

Specified by:

getOperation in interface MessageExchange

getPortType

public javax.wsdl.PortType getPortType()

Specified by:

getPortType in interface MessageExchange

getDAO

public MessageExchangeDAO getDAO()

createMessage

public Message createMessage(javax.xml.namespace.QName msgType)

Specified by:

createMessage in interface MessageExchange

setEndpointReference

public void setEndpointReference(EndpointReference ref)

getEndpointReference

public EndpointReference getEndpointReference()
                                       throws BpelEngineException

Specified by:

getEndpointReference in interface MessageExchange

Throws:

BpelEngineException

getProperty

public java.lang.String getProperty(java.lang.String key)

Specified by:

getProperty in interface MessageExchange

setProperty

public void setProperty(java.lang.String key,
                        java.lang.String value)

Specified by:

setProperty in interface MessageExchange

getPropertyNames

public java.util.Set<java.lang.String> getPropertyNames()

Specified by:

getPropertyNames in interface MessageExchange

getSubscriberCount

public int getSubscriberCount()

setSubscriberCount

public void setSubscriberCount(int subscriberCount)

release

public void release()

Specified by:

release in interface MessageExchange

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

responseReceived

protected void responseReceived()