public class PartnerRoleMessageExchangeImpl extends java.lang.Object implements PartnerRoleMessageExchange
MessageExchange.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 |
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID| Modifier | Constructor and Description |
|---|---|
protected |
PartnerRoleMessageExchangeImpl(BpelEngineImpl engine,
MessageExchangeDAO dao,
javax.wsdl.PortType portType,
javax.wsdl.Operation operation,
EndpointReference epr,
EndpointReference myRoleEPR,
PartnerRoleChannel channel) |
| Modifier and Type | Method and Description |
|---|---|
Message |
createMessage(javax.xml.namespace.QName msgType)
Create a message associated with this exchange.
|
javax.xml.namespace.QName |
getCaller()
Get the identifier of the process that created this message exchange.
|
PartnerRoleChannel |
getChannel()
Get the communication channel.
|
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).
|
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?).
|
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.
|
MessageExchange.Status |
getStatus()
Get the message exchange status.
|
int |
getSubscriberCount() |
boolean |
isTransactionPropagated() |
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()
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.
|
protected void |
responseReceived() |
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 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
protected PartnerRoleMessageExchangeImpl(BpelEngineImpl engine, MessageExchangeDAO dao, javax.wsdl.PortType portType, javax.wsdl.Operation operation, EndpointReference epr, EndpointReference myRoleEPR, PartnerRoleChannel channel)
public void replyOneWayOk()
PartnerRoleMessageExchangereplyOneWayOk in interface PartnerRoleMessageExchangepublic void replyAsync()
PartnerRoleMessageExchangereplyAsync in interface PartnerRoleMessageExchangepublic void replyWithFault(javax.xml.namespace.QName faultType,
Message outputFaultMessage)
throws BpelEngineException
PartnerRoleMessageExchangereplyWithFault in interface PartnerRoleMessageExchangefaultType - fault typeoutputFaultMessage - the input messageBpelEngineExceptionpublic void reply(Message response) throws BpelEngineException
PartnerRoleMessageExchangereply in interface PartnerRoleMessageExchangeresponse - the response from the partnerBpelEngineExceptionpublic void replyWithFailure(MessageExchange.FailureType type, java.lang.String description, org.w3c.dom.Element details) throws BpelEngineException
PartnerRoleMessageExchangereplyWithFailure in interface PartnerRoleMessageExchangetype - type of failuredescription - description of failureBpelEngineExceptionpublic javax.xml.namespace.QName getCaller()
PartnerRoleMessageExchangegetCaller in interface PartnerRoleMessageExchangepublic java.lang.String toString()
public PartnerRoleChannel getChannel()
PartnerRoleMessageExchangegetChannel in interface PartnerRoleMessageExchangepublic EndpointReference getMyRoleEndpointReference()
PartnerRoleMessageExchangeEndpointReference 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 PartnerRoleMessageExchangepublic 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 MessageExchangeprotected void responseReceived()