|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.bpel.engine.UnreliableMyRoleMessageExchangeImpl
org.apache.ode.bpel.engine.BrokeredUnreliableMyRoleMessageExchangeImpl
public class BrokeredUnreliableMyRoleMessageExchangeImpl
An unreliable MEP that delegates messages to a list of subscribers
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.AckType, MessageExchange.FailureType, MessageExchange.MessageExchangePattern, MessageExchange.Status |
Field Summary | |
---|---|
protected static Messages |
__msgs
|
protected javax.xml.namespace.QName |
_callee
|
protected java.lang.String |
_clientId
|
protected MyRoleMessageExchange.CorrelationStatus |
_cstatus
|
protected MessageExchange.FailureType |
_failureType
|
Fields inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
---|
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_MYROLE_TRANSACTED, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID |
Constructor Summary | |
---|---|
BrokeredUnreliableMyRoleMessageExchangeImpl(ODEProcess process,
java.util.List<MyRoleMessageExchange> subscribers,
java.lang.String mexId,
MyRoleMessageExchange template)
Creates a new BrokeredUnreliableMyRoleMessageExchangeImpl object. |
Method Summary | ||
---|---|---|
protected void |
assertTransaction()
|
|
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. |
|
protected
|
doInTX(org.apache.ode.bpel.engine.MessageExchangeImpl.InDbAction<T> action)
|
|
protected MessageExchangeDAO |
doInvoke()
|
|
boolean |
equals(java.lang.Object other)
|
|
MessageExchange.AckType |
getAckType()
Fool the engine into thinking I'm one-way, wherever possible |
|
java.lang.String |
getClientId()
Get the previously associated client key for this exchange. |
|
MyRoleMessageExchange.CorrelationStatus |
getCorrelationStatus()
Get the correlation state of the the invocation. |
|
protected MessageExchangeDAO |
getDAO()
Get the DAO object. |
|
EndpointReference |
getEndpointReference()
Use the EPR of one of the subscribers as my EPR |
|
MessageExchange.FailureType |
getFailureType()
Get the type of failure. |
|
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?). |
|
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()
Use the response from one of the subscribers as my response |
|
javax.xml.namespace.QName |
getServiceName()
Get the name of the service targetted in this message exchange. |
|
MessageExchange.Status |
getStatus()
Return the status of one of the subscribers |
|
long |
getTimeout()
Get the time-out in ms. |
|
java.util.concurrent.Future<MessageExchange.Status> |
invokeAsync()
Propagate the invoke asynchronous call to each subscriber |
|
MessageExchange.Status |
invokeBlocking()
Propagate the invoke blocking call to each subscriber |
|
void |
invokeReliable()
Invoke a reliable process: this method must be invoked in a transaction. |
|
MessageExchange.Status |
invokeTransacted()
Invoke a transactional process: this method must be invoked in a transaction. |
|
boolean |
isSafe()
Report whether the operation is "safe" in the sense of the WSDL1.2 meaning of the term. |
|
boolean |
isTransactional()
Indicates whether a transactions in associated with the message exchange. |
|
void |
release()
Should be called by the external partner when it's done with the message exchange. |
|
void |
release(boolean instanceSucceeded)
|
|
void |
save(MessageExchangeDAO dao)
|
|
void |
setEndpointReference(EndpointReference ref)
|
|
void |
setProperty(java.lang.String key,
java.lang.String value)
Set a message exchange property. |
|
void |
setRequest(Message request)
Propagate set request call to every subscriber |
|
void |
setTimeout(long timeout)
Propagate set timeout call to every subscriber |
|
java.lang.String |
toString()
|
Methods inherited from class org.apache.ode.bpel.engine.UnreliableMyRoleMessageExchangeImpl |
---|
getInvocationStyle, onAsyncAck |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.ode.bpel.iapi.MessageExchange |
---|
createMessage, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperation, getOperationName, getPortType, getProperty, getPropertyNames, getRequest, getTimeout, isSafe, isTransactional, release, setProperty |
Field Detail |
---|
protected final javax.xml.namespace.QName _callee
protected MyRoleMessageExchange.CorrelationStatus _cstatus
protected java.lang.String _clientId
protected static final Messages __msgs
protected MessageExchange.FailureType _failureType
Constructor Detail |
---|
public BrokeredUnreliableMyRoleMessageExchangeImpl(ODEProcess process, java.util.List<MyRoleMessageExchange> subscribers, java.lang.String mexId, MyRoleMessageExchange template)
process
- subscribers
- mexId
- template
- Method Detail |
---|
public java.util.concurrent.Future<MessageExchange.Status> invokeAsync()
invokeAsync
in interface MyRoleMessageExchange
invokeAsync
in class UnreliableMyRoleMessageExchangeImpl
public MessageExchange.Status invokeBlocking() throws BpelEngineException, java.util.concurrent.TimeoutException
invokeBlocking
in interface MyRoleMessageExchange
invokeBlocking
in class UnreliableMyRoleMessageExchangeImpl
BpelEngineException
- BpelEngineException
java.util.concurrent.TimeoutException
- TimeoutExceptionpublic MessageExchange.AckType getAckType()
getAckType
in interface MessageExchange
public EndpointReference getEndpointReference() throws BpelEngineException
getEndpointReference
in interface MessageExchange
BpelEngineException
- BpelEngineExceptionpublic Message getResponse()
getResponse
in interface MessageExchange
public void setRequest(Message request)
setRequest
in interface MyRoleMessageExchange
request
- requestpublic void setTimeout(long timeout)
setTimeout
in interface MessageExchange
timeout
- timeoutpublic MessageExchange.Status getStatus()
getStatus
in interface MessageExchange
public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
MyRoleMessageExchange
CorrelationType
for details).
getCorrelationStatus
in interface MyRoleMessageExchange
public void save(MessageExchangeDAO dao)
public MessageExchange.FailureType getFailureType()
MyRoleMessageExchange
getFailureType
in interface MyRoleMessageExchange
public java.lang.String getClientId()
MyRoleMessageExchange
getClientId
in interface MyRoleMessageExchange
public void invokeReliable()
MyRoleMessageExchange
MessageExchangeContext#onReliableReply(MyRoleMessageExchange)
.
invokeReliable
in interface MyRoleMessageExchange
public MessageExchange.Status invokeTransacted() throws BpelEngineException
MyRoleMessageExchange
invokeTransacted
in interface MyRoleMessageExchange
BpelEngineException
public javax.xml.namespace.QName getServiceName()
MyRoleMessageExchange
getServiceName
in interface MyRoleMessageExchange
public java.lang.String toString()
public void complete()
MyRoleMessageExchange
complete
in interface MyRoleMessageExchange
public void release(boolean instanceSucceeded)
release
in interface MyRoleMessageExchange
protected MessageExchangeDAO doInvoke()
protected Message cloneMessage(Message message)
message
-
public boolean equals(java.lang.Object other)
equals
in class java.lang.Object
public boolean isSafe()
MessageExchange
isSafe
in interface MessageExchange
true
if the operation is safe, false
otherwise.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 isTransactional() throws BpelEngineException
MessageExchange
true
. ASYNC and BLOCKING styles will always have this set to false
.
isTransactional
in interface MessageExchange
true if there is a transaction associated with the object, false
otherwise.
- Throws:
BpelEngineException
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 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 Message getRequest()
MessageExchange
getRequest
in interface MessageExchange
public Message createMessage(javax.xml.namespace.QName msgType)
MessageExchange
createMessage
in interface MessageExchange
msgType
- message type
Message
public void setEndpointReference(EndpointReference ref)
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 long getTimeout()
MessageExchange
getTimeout
in interface MessageExchange
public void release()
MessageExchange
release
in interface MessageExchange
protected void assertTransaction()
protected <T> T doInTX(org.apache.ode.bpel.engine.MessageExchangeImpl.InDbAction<T> action)
protected MessageExchangeDAO getDAO()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |