org.apache.ode.bpel.engine
Class PartnerRoleMessageExchangeImpl

java.lang.Object
  extended by 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 Class Summary
 
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)
           
 
Method Summary
 org.apache.ode.bpel.iapi.Message createMessage(javax.xml.namespace.QName msgType)
           
 javax.xml.namespace.QName getCaller()
           
 org.apache.ode.bpel.iapi.PartnerRoleChannel getChannel()
           
 org.apache.ode.bpel.dao.MessageExchangeDAO getDAO()
           
 org.apache.ode.bpel.iapi.EndpointReference getEndpointReference()
           
 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()
           
 org.apache.ode.bpel.iapi.EndpointReference getMyRoleEndpointReference()
           
 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()
           
 org.apache.ode.bpel.iapi.MessageExchange.Status getStatus()
           
 int getSubscriberCount()
           
 boolean isTransactionPropagated()
           
 void release()
           
 void reply(org.apache.ode.bpel.iapi.Message response)
           
 void replyAsync()
           
 void replyOneWayOk()
           
 void replyWithFailure(org.apache.ode.bpel.iapi.MessageExchange.FailureType type, java.lang.String description, org.w3c.dom.Element details)
           
 void replyWithFault(javax.xml.namespace.QName faultType, org.apache.ode.bpel.iapi.Message outputFaultMessage)
           
protected  void responseReceived()
           
 void setEndpointReference(org.apache.ode.bpel.iapi.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
 
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
 

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

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)
Method Detail

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