public class MyRoleMessageExchangeImpl extends java.lang.Object implements MyRoleMessageExchange
MyRoleMessageExchange.CorrelationStatusMessageExchange.FailureType, MessageExchange.MessageExchangePattern, MessageExchange.Status| Modifier and Type | Field and Description |
|---|---|
protected static Messages |
__msgs |
protected MessageExchangeDAO |
_dao |
protected BpelEngineImpl |
_engine |
protected EndpointReference |
_epr |
protected java.lang.Long |
_iid
Process-Instance identifier.
|
protected javax.wsdl.Operation |
_operation |
protected javax.wsdl.PortType |
_portType |
protected BpelProcess |
_process |
protected static java.util.Map<java.lang.String,org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.ResponseCallback> |
_waitingCallbacks |
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID| Constructor and Description |
|---|
MyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
MessageExchangeDAO mexdao) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
cloneMessage(Message message)
Return a deep clone of the given message
|
void |
complete()
Complete the message, exchange: indicates that the client has receive the
response (if any).
|
Message |
createMessage(javax.xml.namespace.QName msgType)
Create a message associated with this exchange.
|
java.lang.String |
getClientId()
Get the previously associated client key for this exchange.
|
MyRoleMessageExchange.CorrelationStatus |
getCorrelationStatus()
Get the correlation state of the the invocation.
|
MessageExchangeDAO |
getDAO() |
EndpointReference |
getEndpointReference()
Get a reference to the end-point targeted by this message exchange.
|
javax.xml.namespace.QName |
getFault()
Get the fault type.
|
java.lang.String |
getFaultExplanation() |
Message |
getFaultResponse()
Get the fault resposne message.
|
java.lang.String |
getMessageExchangeId()
Get the message exchange identifier.
|
MessageExchange.MessageExchangePattern |
getMessageExchangePattern()
Return the type of message-exchange that resulted form this invocation
(request only/request-respone).
|
javax.wsdl.Operation |
getOperation()
Get the operation description for this message exchange.
|
java.lang.String |
getOperationName()
Get the name of the operation (WSDL 1.1) / message exchange (WSDL 1.2?).
|
MessageExchange.MessageExchangePattern |
getPattern() |
javax.wsdl.PortType |
getPortType()
Get the port type description for this message exchange.
|
java.lang.String |
getProperty(java.lang.String key)
Get a message exchange property.
|
java.util.Set<java.lang.String> |
getPropertyNames()
Get a set containing the names of the defined properties.
|
Message |
getRequest()
Get the request message.
|
Message |
getResponse()
Get the response message.
|
javax.xml.namespace.QName |
getServiceName()
Get the name of the service targetted in this message exchange.
|
MessageExchange.Status |
getStatus()
Get the message exchange status.
|
int |
getSubscriberCount() |
java.util.concurrent.Future |
invoke(Message request)
"Invoke" a process hosted by the BPEL engine.
|
boolean |
isAsynchronous() |
boolean |
isTransactionPropagated() |
void |
release()
Should be called by the external partner when it's done with the
message exchange.
|
void |
release(boolean instanceSucceeded)
Should be called by the external partner when it's done with the
message exchange.
|
protected void |
responseReceived() |
void |
setClientId(java.lang.String clientKey)
Associate a client key with this message exchange.
|
void |
setCorrelationStatus(MyRoleMessageExchange.CorrelationStatus status) |
void |
setEndpointReference(EndpointReference ref) |
void |
setProperty(java.lang.String key,
java.lang.String value)
Set a message exchange property.
|
void |
setSubscriberCount(int subscriberCount) |
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcreateMessage, getEndpointReference, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperation, getOperationName, getPortType, getProperty, getPropertyNames, getRequest, getResponse, getStatus, isTransactionPropagated, release, setPropertyprotected BpelProcess _process
protected static java.util.Map<java.lang.String,org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.ResponseCallback> _waitingCallbacks
protected static final Messages __msgs
protected java.lang.Long _iid
protected javax.wsdl.PortType _portType
protected javax.wsdl.Operation _operation
protected final BpelEngineImpl _engine
protected EndpointReference _epr
protected MessageExchangeDAO _dao
public MyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, MessageExchangeDAO mexdao)
public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
MyRoleMessageExchangeCorrelationType for details).getCorrelationStatus in interface MyRoleMessageExchangepublic void setCorrelationStatus(MyRoleMessageExchange.CorrelationStatus status)
public java.util.concurrent.Future invoke(Message request)
MyRoleMessageExchangeMessageExchange.getStatus()
method. It is possible that the response for the operation is not
immediately available (i.e the call to MyRoleMessageExchange.invoke(Message) will
return before a response is available). In such cases,
MessageExchange.getStatus() == Status#ASYNC and the
integration layer will receive an asynchronous notification from the BPEL
engine via the
MessageExchangeContext.onAsyncReply(MyRoleMessageExchange) when
the response become available.invoke in interface MyRoleMessageExchangepublic void complete()
MyRoleMessageExchangecomplete in interface MyRoleMessageExchangepublic javax.xml.namespace.QName getServiceName()
MyRoleMessageExchangegetServiceName in interface MyRoleMessageExchangepublic void setClientId(java.lang.String clientKey)
MyRoleMessageExchangesetClientId in interface MyRoleMessageExchangepublic java.lang.String getClientId()
MyRoleMessageExchangegetClientId in interface MyRoleMessageExchangepublic java.lang.String toString()
public boolean isAsynchronous()
public void release(boolean instanceSucceeded)
MyRoleMessageExchangerelease in interface MyRoleMessageExchangeprotected Message cloneMessage(Message message)
message - protected void responseReceived()
public java.lang.String getMessageExchangeId()
throws BpelEngineException
MessageExchangegetMessageExchangeId in interface MessageExchangeBpelEngineExceptionpublic java.lang.String getOperationName()
throws BpelEngineException
MessageExchangegetOperationName in interface MessageExchangeBpelEngineExceptionpublic MessageExchange.MessageExchangePattern getMessageExchangePattern()
MessageExchangeMessageExchange.MessageExchangePattern.REQUEST_RESPONSE message-exchange was
created, then the caller should expect a response in the future.getMessageExchangePattern in interface MessageExchangepublic boolean isTransactionPropagated()
throws BpelEngineException
isTransactionPropagated in interface MessageExchangeBpelEngineExceptionpublic Message getResponse()
MessageExchangegetResponse in interface MessageExchangepublic javax.xml.namespace.QName getFault()
MessageExchangegetFault in interface MessageExchangenull if not available/applicable.public Message getFaultResponse()
MessageExchangegetFaultResponse in interface MessageExchangenull if not available/applicable.public java.lang.String getFaultExplanation()
getFaultExplanation in interface MessageExchangepublic MessageExchange.MessageExchangePattern getPattern()
public MessageExchange.Status getStatus()
MessageExchangegetStatus in interface MessageExchangepublic Message getRequest()
MessageExchangegetRequest in interface MessageExchangepublic javax.wsdl.Operation getOperation()
MessageExchangegetOperation in interface MessageExchangenull if not availblepublic javax.wsdl.PortType getPortType()
MessageExchangegetPortType in interface MessageExchangenull if not available.public MessageExchangeDAO getDAO()
public Message createMessage(javax.xml.namespace.QName msgType)
MessageExchangecreateMessage in interface MessageExchangemsgType - message typeMessagepublic void setEndpointReference(EndpointReference ref)
public EndpointReference getEndpointReference() throws BpelEngineException
MessageExchangegetEndpointReference in interface MessageExchangeBpelEngineExceptionpublic java.lang.String getProperty(java.lang.String key)
MessageExchangegetProperty in interface MessageExchangekey - property keypublic void setProperty(java.lang.String key,
java.lang.String value)
MessageExchangesetProperty in interface MessageExchangekey - property keyvalue - property valuepublic java.util.Set<java.lang.String> getPropertyNames()
MessageExchangegetPropertyNames in interface MessageExchangepublic int getSubscriberCount()
public void setSubscriberCount(int subscriberCount)
public void release()
MessageExchangerelease in interface MessageExchange