org.apache.ode.bpel.engine
Class BrokeredMyRoleMessageExchangeImpl
java.lang.Object
org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
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 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 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. |
| 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 |
__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
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 -
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