org.apache.ode.bpel.engine
Class PartnerRoleMessageExchangeImpl
java.lang.Object
org.apache.ode.bpel.engine.PartnerRoleMessageExchangeImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.iapi.MessageExchange, org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
public class PartnerRoleMessageExchangeImpl
- extends java.lang.Object
- implements org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
| 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 |
protected |
PartnerRoleMessageExchangeImpl(BpelEngineImpl engine,
org.apache.ode.bpel.dao.MessageExchangeDAO dao,
javax.wsdl.PortType portType,
javax.wsdl.Operation operation,
org.apache.ode.bpel.iapi.EndpointReference epr,
org.apache.ode.bpel.iapi.EndpointReference myRoleEPR,
org.apache.ode.bpel.iapi.PartnerRoleChannel channel)
|
| 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 |
__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
PartnerRoleMessageExchangeImpl
protected PartnerRoleMessageExchangeImpl(BpelEngineImpl engine,
org.apache.ode.bpel.dao.MessageExchangeDAO dao,
javax.wsdl.PortType portType,
javax.wsdl.Operation operation,
org.apache.ode.bpel.iapi.EndpointReference epr,
org.apache.ode.bpel.iapi.EndpointReference myRoleEPR,
org.apache.ode.bpel.iapi.PartnerRoleChannel channel)
replyOneWayOk
public void replyOneWayOk()
- Specified by:
replyOneWayOk in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
replyAsync
public void replyAsync()
- Specified by:
replyAsync in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
replyWithFault
public void replyWithFault(javax.xml.namespace.QName faultType,
org.apache.ode.bpel.iapi.Message outputFaultMessage)
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
replyWithFault in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
reply
public void reply(org.apache.ode.bpel.iapi.Message response)
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
reply in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
replyWithFailure
public void replyWithFailure(org.apache.ode.bpel.iapi.MessageExchange.FailureType type,
java.lang.String description,
org.w3c.dom.Element details)
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
replyWithFailure in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
getCaller
public javax.xml.namespace.QName getCaller()
- Specified by:
getCaller in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
toString
public java.lang.String toString()
getChannel
public org.apache.ode.bpel.iapi.PartnerRoleChannel getChannel()
- Specified by:
getChannel in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
getMyRoleEndpointReference
public org.apache.ode.bpel.iapi.EndpointReference getMyRoleEndpointReference()
- Specified by:
getMyRoleEndpointReference in interface org.apache.ode.bpel.iapi.PartnerRoleMessageExchange
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
getResponse
public org.apache.ode.bpel.iapi.Message getResponse()
- Specified by:
getResponse in interface org.apache.ode.bpel.iapi.MessageExchange
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()
getStatus
public org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
- Specified by:
getStatus in interface org.apache.ode.bpel.iapi.MessageExchange
getRequest
public org.apache.ode.bpel.iapi.Message getRequest()
- Specified by:
getRequest 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
getPortType
public javax.wsdl.PortType getPortType()
- Specified by:
getPortType 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)
getEndpointReference
public org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
throws org.apache.ode.bpel.iapi.BpelEngineException
- Specified by:
getEndpointReference in interface org.apache.ode.bpel.iapi.MessageExchange
- Throws:
org.apache.ode.bpel.iapi.BpelEngineException
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
getSubscriberCount
public int getSubscriberCount()
setSubscriberCount
public void setSubscriberCount(int subscriberCount)
release
public void release()
- Specified by:
release in interface org.apache.ode.bpel.iapi.MessageExchange
responseReceived
protected void responseReceived()