org.apache.ode.bpel.engine
Class BrokeredMyRoleMessageExchangeImpl

java.lang.Object
  extended by org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
      extended by org.apache.ode.bpel.engine.BrokeredMyRoleMessageExchangeImpl
All Implemented Interfaces:
org.apache.ode.bpel.iapi.MessageExchange, org.apache.ode.bpel.iapi.MyRoleMessageExchange

public class BrokeredMyRoleMessageExchangeImpl
extends MyRoleMessageExchangeImpl

A reliable MEP that delegates messages to a list of subscribers


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
           
 
Fields inherited from class org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
_process, _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
BrokeredMyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, java.util.List<org.apache.ode.bpel.iapi.MyRoleMessageExchange> subscribers, org.apache.ode.bpel.dao.MessageExchangeDAO mexDao, org.apache.ode.bpel.iapi.MyRoleMessageExchange template)
          Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.
 
Method Summary
 org.apache.ode.bpel.iapi.Message createMessage(javax.xml.namespace.QName msgType)
           
 org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
           
 org.apache.ode.bpel.dao.MessageExchangeDAO getDAO()
           
 org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
          Use the EPR of one of the subscribers as my EPR
 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()
          Use the response from one of the subscribers as my response
 org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
           
 int getSubscriberCount()
           
 java.util.concurrent.Future invoke(org.apache.ode.bpel.iapi.Message request)
          Propagate the invoke reliable call to each subscriber
 boolean isTransactionPropagated()
           
 void release()
           
 void setEndpointReference(org.apache.ode.bpel.iapi.EndpointReference ref)
           
 void setProperty(java.lang.String key, java.lang.String value)
           
 void setSubscriberCount(int subscriberCount)
           
 
Methods inherited from class org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
cloneMessage, complete, getClientId, getServiceName, isAsynchronous, release, responseReceived, setClientId, setCorrelationStatus, 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, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperationName, getProperty, getPropertyNames, getRequest, isTransactionPropagated, release, setProperty
 

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 org.apache.ode.bpel.iapi.EndpointReference _epr

_dao

protected org.apache.ode.bpel.dao.MessageExchangeDAO _dao
Constructor Detail

BrokeredMyRoleMessageExchangeImpl

public BrokeredMyRoleMessageExchangeImpl(BpelProcess process,
                                         BpelEngineImpl engine,
                                         java.util.List<org.apache.ode.bpel.iapi.MyRoleMessageExchange> subscribers,
                                         org.apache.ode.bpel.dao.MessageExchangeDAO mexDao,
                                         org.apache.ode.bpel.iapi.MyRoleMessageExchange template)
Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.

Parameters:
process -
subscribers -
mexId -
oplink -
template -
Method Detail

invoke

public java.util.concurrent.Future invoke(org.apache.ode.bpel.iapi.Message request)
Propagate the invoke reliable call to each subscriber

Specified by:
invoke in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
Overrides:
invoke in class MyRoleMessageExchangeImpl

getEndpointReference

public org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
                                                                throws org.apache.ode.bpel.iapi.BpelEngineException
Use the EPR of one of the subscribers as my EPR

Specified by:
getEndpointReference in interface org.apache.ode.bpel.iapi.MessageExchange
Returns:
type
Throws:
org.apache.ode.bpel.iapi.BpelEngineException - BpelEngineException

getResponse

public org.apache.ode.bpel.iapi.Message getResponse()
Use the response from one of the subscribers as my response

Specified by:
getResponse in interface org.apache.ode.bpel.iapi.MessageExchange
Returns:
type

getStatus

public org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
Specified by:
getStatus in interface org.apache.ode.bpel.iapi.MessageExchange

getCorrelationStatus

public org.apache.ode.bpel.iapi.MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
Specified by:
getCorrelationStatus in interface org.apache.ode.bpel.iapi.MyRoleMessageExchange
Overrides:
getCorrelationStatus in class MyRoleMessageExchangeImpl

getSubscriberCount

public int getSubscriberCount()

setSubscriberCount

public void setSubscriberCount(int subscriberCount)

getPortType

public javax.wsdl.PortType getPortType()
Specified by:
getPortType 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

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

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()

getRequest

public org.apache.ode.bpel.iapi.Message getRequest()
Specified by:
getRequest 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)

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

release

public void release()
Specified by:
release in interface org.apache.ode.bpel.iapi.MessageExchange