|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.bpel.engine.MyRoleMessageExchangeImpl
public class MyRoleMessageExchangeImpl
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MyRoleMessageExchange |
---|
MyRoleMessageExchange.CorrelationStatus |
Nested classes/interfaces inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
---|
MessageExchange.FailureType, MessageExchange.MessageExchangePattern, MessageExchange.Status |
Field Summary | |
---|---|
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
|
Fields inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
---|
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID |
Constructor Summary | |
---|---|
MyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
MessageExchangeDAO mexdao)
|
Method Summary | |
---|---|
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()
|
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 |
---|
protected 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
Constructor Detail |
---|
public MyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, MessageExchangeDAO mexdao)
Method Detail |
---|
public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
MyRoleMessageExchange
CorrelationType
for details).
getCorrelationStatus
in interface MyRoleMessageExchange
public void setCorrelationStatus(MyRoleMessageExchange.CorrelationStatus status)
public java.util.concurrent.Future invoke(Message request)
MyRoleMessageExchange
MessageExchange.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 MyRoleMessageExchange
public void complete()
MyRoleMessageExchange
complete
in interface MyRoleMessageExchange
public javax.xml.namespace.QName getServiceName()
MyRoleMessageExchange
getServiceName
in interface MyRoleMessageExchange
public void setClientId(java.lang.String clientKey)
MyRoleMessageExchange
setClientId
in interface MyRoleMessageExchange
public java.lang.String getClientId()
MyRoleMessageExchange
getClientId
in interface MyRoleMessageExchange
public java.lang.String toString()
public boolean isAsynchronous()
public void release(boolean instanceSucceeded)
MyRoleMessageExchange
release
in interface MyRoleMessageExchange
protected Message cloneMessage(Message message)
message
-
protected void responseReceived()
public java.lang.String getMessageExchangeId() throws BpelEngineException
MessageExchange
getMessageExchangeId
in interface MessageExchange
BpelEngineException
public java.lang.String getOperationName() throws BpelEngineException
MessageExchange
getOperationName
in interface MessageExchange
BpelEngineException
public MessageExchange.MessageExchangePattern getMessageExchangePattern()
MessageExchange
MessageExchange.MessageExchangePattern.REQUEST_RESPONSE
message-exchange was
created, then the caller should expect a response in the future.
getMessageExchangePattern
in interface MessageExchange
public boolean isTransactionPropagated() throws BpelEngineException
isTransactionPropagated
in interface MessageExchange
BpelEngineException
public Message getResponse()
MessageExchange
getResponse
in interface MessageExchange
public javax.xml.namespace.QName getFault()
MessageExchange
getFault
in interface MessageExchange
null
if not available/applicable.public Message getFaultResponse()
MessageExchange
getFaultResponse
in interface MessageExchange
null
if not available/applicable.public java.lang.String getFaultExplanation()
getFaultExplanation
in interface MessageExchange
public MessageExchange.MessageExchangePattern getPattern()
public MessageExchange.Status getStatus()
MessageExchange
getStatus
in interface MessageExchange
public Message getRequest()
MessageExchange
getRequest
in interface MessageExchange
public javax.wsdl.Operation getOperation()
MessageExchange
getOperation
in interface MessageExchange
null
if not availblepublic javax.wsdl.PortType getPortType()
MessageExchange
getPortType
in interface MessageExchange
null
if not available.public MessageExchangeDAO getDAO()
public Message createMessage(javax.xml.namespace.QName msgType)
MessageExchange
createMessage
in interface MessageExchange
msgType
- message type
Message
public void setEndpointReference(EndpointReference ref)
public EndpointReference getEndpointReference() throws BpelEngineException
MessageExchange
getEndpointReference
in interface MessageExchange
BpelEngineException
public java.lang.String getProperty(java.lang.String key)
MessageExchange
getProperty
in interface MessageExchange
key
- property key
public void setProperty(java.lang.String key, java.lang.String value)
MessageExchange
setProperty
in interface MessageExchange
key
- property keyvalue
- property valuepublic java.util.Set<java.lang.String> getPropertyNames()
MessageExchange
getPropertyNames
in interface MessageExchange
public int getSubscriberCount()
public void setSubscriberCount(int subscriberCount)
public void release()
MessageExchange
release
in interface MessageExchange
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |