|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ode.bpel.engine.ReliablePartnerRoleMessageExchangeImpl
public class ReliablePartnerRoleMessageExchangeImpl
Nested Class Summary |
---|
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 java.util.concurrent.locks.Lock |
_accessLock
|
protected java.util.concurrent.locks.Condition |
_acked
|
protected MessageExchange.FailureType |
_failureType
|
protected java.lang.String |
_foreignKey
|
protected EndpointReference |
_myRoleEPR
|
protected PartnerRoleChannel |
_partnerRoleChannel
|
protected java.lang.String |
_responseChannel
|
protected org.apache.ode.bpel.engine.PartnerRoleMessageExchangeImpl.State |
_state
|
protected java.util.concurrent.locks.Condition |
_stateChanged
|
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 | |
---|---|
ReliablePartnerRoleMessageExchangeImpl(ODEProcess process,
long iid,
java.lang.String mexId,
PartnerLinkModel oplink,
javax.wsdl.Operation op,
EndpointReference epr,
EndpointReference myRoleEPR,
PartnerRoleChannel partnerRoleChannel)
|
Method Summary | ||
---|---|---|
protected void |
assertTransaction()
|
|
protected void |
asyncACK()
Resume an instance. |
|
protected void |
checkReplyContextOk()
|
|
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)
|
|
boolean |
equals(java.lang.Object other)
|
|
MessageExchange.AckType |
getAckType()
|
|
javax.xml.namespace.QName |
getCaller()
Get the identifier of the process that created this message exchange. |
|
protected MessageExchangeDAO |
getDAO()
Get the DAO object. |
|
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. |
|
InvocationStyle |
getInvocationStyle()
Get the invocation style for this message exchange. |
|
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). |
|
EndpointReference |
getMyRoleEndpointReference()
Get the EndpointReference associated with the my-role of the partner link to which this message exchange belongs. |
|
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?). |
|
PartnerRoleChannel |
getPartnerRoleChannel()
Get the communication channel. |
|
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. |
|
MessageExchange.Status |
getStatus()
Get the message exchange status. |
|
long |
getTimeout()
Get the time-out in ms. |
|
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 |
reply(Message response)
Indicate that the partner has responded to the message exchange. |
|
void |
replyAsync(java.lang.String foreignKey)
Indicate that the response to the request/response operation is not yet available and that the response will be delivered asynchronously. |
|
void |
replyOneWayOk()
Indicate that the partner processed the one-way invocation successfully. |
|
void |
replyWithFailure(MessageExchange.FailureType type,
java.lang.String description,
org.w3c.dom.Element details)
Indicate that the partner has failed to process the message exchange. |
|
void |
replyWithFault(javax.xml.namespace.QName faultType,
Message outputFaultMessage)
Indicate that the partner faulted in processing the message exchange. |
|
void |
setEndpointReference(EndpointReference ref)
|
|
void |
setProperty(java.lang.String key,
java.lang.String value)
Set a message exchange property. |
|
void |
setTimeout(long timeout)
Set the time-out in ms |
|
java.lang.String |
toString()
|
|
boolean |
waitForAck(long timeout)
|
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, getAckType, getEndpointReference, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperation, getOperationName, getPortType, getProperty, getPropertyNames, getRequest, getResponse, getStatus, getTimeout, isSafe, isTransactional, release, setProperty, setTimeout |
Field Detail |
---|
protected final PartnerRoleChannel _partnerRoleChannel
protected EndpointReference _myRoleEPR
protected java.lang.String _responseChannel
protected volatile java.lang.String _foreignKey
protected java.util.concurrent.locks.Lock _accessLock
protected java.util.concurrent.locks.Condition _stateChanged
protected java.util.concurrent.locks.Condition _acked
protected org.apache.ode.bpel.engine.PartnerRoleMessageExchangeImpl.State _state
protected static final Messages __msgs
protected MessageExchange.FailureType _failureType
Constructor Detail |
---|
public ReliablePartnerRoleMessageExchangeImpl(ODEProcess process, long iid, java.lang.String mexId, PartnerLinkModel oplink, javax.wsdl.Operation op, EndpointReference epr, EndpointReference myRoleEPR, PartnerRoleChannel partnerRoleChannel)
Method Detail |
---|
protected void checkReplyContextOk()
public void replyAsync(java.lang.String foreignKey)
PartnerRoleMessageExchange
replyAsync
in interface PartnerRoleMessageExchange
foreignKey
- "foreign" key that is used to identify this message exchange.protected void asyncACK()
MessageExchangeContext.invokePartnerReliable(PartnerRoleMessageExchange)
or
MessageExchangeContext#invokePartnerAsynch(PartnerRoleMessageExchange)
. Note that this is actually the common case
for ASYNC and RELIABLE invocations.
public InvocationStyle getInvocationStyle()
MessageExchange
getInvocationStyle
in interface MessageExchange
public void replyOneWayOk()
PartnerRoleMessageExchange
replyOneWayOk
in interface PartnerRoleMessageExchange
public void replyWithFault(javax.xml.namespace.QName faultType, Message outputFaultMessage) throws BpelEngineException
PartnerRoleMessageExchange
replyWithFault
in interface PartnerRoleMessageExchange
faultType
- fault typeoutputFaultMessage
- the input message
BpelEngineException
public void reply(Message response) throws BpelEngineException
PartnerRoleMessageExchange
reply
in interface PartnerRoleMessageExchange
response
- the response from the partner
BpelEngineException
public void replyWithFailure(MessageExchange.FailureType type, java.lang.String description, org.w3c.dom.Element details) throws BpelEngineException
PartnerRoleMessageExchange
replyWithFailure
in interface PartnerRoleMessageExchange
type
- type of failuredescription
- description of failure
BpelEngineException
public javax.xml.namespace.QName getCaller()
PartnerRoleMessageExchange
getCaller
in interface PartnerRoleMessageExchange
public PartnerRoleChannel getPartnerRoleChannel()
PartnerRoleMessageExchange
getPartnerRoleChannel
in interface PartnerRoleMessageExchange
public EndpointReference getMyRoleEndpointReference()
PartnerRoleMessageExchange
EndpointReference
associated with the my-role of the partner link to which this message exchange belongs.
This method is typically used to provide protocol-specific "callback" mechanisms.
getMyRoleEndpointReference
in interface PartnerRoleMessageExchange
public java.lang.String toString()
public boolean waitForAck(long timeout) throws java.lang.InterruptedException
java.lang.InterruptedException
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 MessageExchange.Status getStatus()
MessageExchange
getStatus
in interface MessageExchange
public MessageExchange.AckType getAckType()
getAckType
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 getResponse()
MessageExchange
getResponse
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 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 long getTimeout()
MessageExchange
getTimeout
in interface MessageExchange
public void setTimeout(long timeout)
MessageExchange
setTimeout
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 |