org.apache.ode.bpel.engine

Class BrokeredMyRoleMessageExchangeImpl

java.lang.Object

org.apache.ode.bpel.engine.MessageExchangeImpl

org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl

org.apache.ode.bpel.engine.BrokeredMyRoleMessageExchangeImpl

All Implemented Interfaces:

MessageExchange, MyRoleMessageExchange

public class BrokeredMyRoleMessageExchangeImpl
extends MyRoleMessageExchangeImpl

A reliable MEP that delegates messages to a list of subscribers

Version:

$Revision$

Author:

$author$

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 inherited from class org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl

_process, _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
BrokeredMyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, java.util.List<MyRoleMessageExchange> subscribers, MessageExchangeDAO mexDao, MyRoleMessageExchange template) Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.

Method Summary

Modifier and Type	Method and Description
MyRoleMessageExchange.CorrelationStatus	getCorrelationStatus()
EndpointReference	getEndpointReference() Use the EPR of one of the subscribers as my EPR
javax.wsdl.Operation	getOperation()
javax.wsdl.PortType	getPortType()
Message	getResponse() Use the response from one of the subscribers as my response
MessageExchange.Status	getStatus()
int	getSubscriberCount()
java.util.concurrent.Future	invoke(Message request) Propagate the invoke reliable call to each subscriber
void	setSubscriberCount(int subscriberCount)

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

cloneMessage, complete, getClientId, getServiceName, invoke, isAsynchronous, release, responseReceived, setClientId, setCorrelationStatus, toString

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

createMessage, getDAO, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperationName, getPattern, getProperty, getPropertyNames, getRequest, isTransactionPropagated, release, setEndpointReference, setProperty

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, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperationName, getProperty, getPropertyNames, getRequest, isTransactionPropagated, release, setProperty

Constructor Detail

BrokeredMyRoleMessageExchangeImpl

public BrokeredMyRoleMessageExchangeImpl(BpelProcess process,
                                         BpelEngineImpl engine,
                                         java.util.List<MyRoleMessageExchange> subscribers,
                                         MessageExchangeDAO mexDao,
                                         MyRoleMessageExchange template)

Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.

Parameters:

process -

subscribers -

mexId -

oplink -

template -

Method Detail

invoke

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

Propagate the invoke reliable call to each subscriber

Specified by:

invoke in interface MyRoleMessageExchange

Overrides:

invoke in class MyRoleMessageExchangeImpl

getEndpointReference

public EndpointReference getEndpointReference()
                                       throws BpelEngineException

Use the EPR of one of the subscribers as my EPR

Specified by:

getEndpointReference in interface MessageExchange

Overrides:

getEndpointReference in class MessageExchangeImpl

Returns:

type

Throws:

BpelEngineException - BpelEngineException

getResponse

public Message getResponse()

Use the response from one of the subscribers as my response

Specified by:

getResponse in interface MessageExchange

Overrides:

getResponse in class MessageExchangeImpl

Returns:

type

getStatus

public MessageExchange.Status getStatus()

Specified by:

getStatus in interface MessageExchange

Overrides:

getStatus in class MessageExchangeImpl

getCorrelationStatus

public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()

Specified by:

getCorrelationStatus in interface MyRoleMessageExchange

Overrides:

getCorrelationStatus in class MyRoleMessageExchangeImpl

getSubscriberCount

public int getSubscriberCount()

Overrides:

getSubscriberCount in class MessageExchangeImpl

setSubscriberCount

public void setSubscriberCount(int subscriberCount)

Overrides:

setSubscriberCount in class MessageExchangeImpl

getPortType

public javax.wsdl.PortType getPortType()

Specified by:

getPortType in interface MessageExchange

Overrides:

getPortType in class MessageExchangeImpl

getOperation

public javax.wsdl.Operation getOperation()

Specified by:

getOperation in interface MessageExchange

Overrides:

getOperation in class MessageExchangeImpl