public class BrokeredMyRoleMessageExchangeImpl extends MyRoleMessageExchangeImpl
MyRoleMessageExchange.CorrelationStatus
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 |
_process, _waitingCallbacks
PROPERTY_SEP_MYROLE_SESSIONID, PROPERTY_SEP_PARTNERROLE_EPR, PROPERTY_SEP_PARTNERROLE_SESSIONID
Constructor and Description |
---|
BrokeredMyRoleMessageExchangeImpl(BpelProcess process,
BpelEngineImpl engine,
java.util.List<MyRoleMessageExchange> subscribers,
MessageExchangeDAO mexDao,
MyRoleMessageExchange template)
Creates a new BrokeredReliableMyRoleMessageExchangeImpl object.
|
Modifier and Type | Method and Description |
---|---|
Message |
createMessage(javax.xml.namespace.QName msgType)
Create a message associated with this exchange.
|
MyRoleMessageExchange.CorrelationStatus |
getCorrelationStatus()
Get the correlation state of the the invocation.
|
MessageExchangeDAO |
getDAO() |
EndpointReference |
getEndpointReference()
Use the EPR of one of the subscribers as my EPR
|
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()
Use the response from one of the subscribers as my response
|
MessageExchange.Status |
getStatus()
Get the message exchange status.
|
int |
getSubscriberCount() |
java.util.concurrent.Future |
invoke(Message request)
Propagate the invoke reliable call to each subscriber
|
boolean |
isTransactionPropagated() |
void |
release()
Should be called by the external partner when it's done with the
message exchange.
|
void |
setEndpointReference(EndpointReference ref) |
void |
setProperty(java.lang.String key,
java.lang.String value)
Set a message exchange property.
|
void |
setSubscriberCount(int subscriberCount) |
cloneMessage, complete, getClientId, getServiceName, isAsynchronous, release, responseReceived, setClientId, setCorrelationStatus, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMessage, getFault, getFaultExplanation, getFaultResponse, getMessageExchangeId, getMessageExchangePattern, getOperationName, getProperty, getPropertyNames, getRequest, isTransactionPropagated, release, setProperty
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 BrokeredMyRoleMessageExchangeImpl(BpelProcess process, BpelEngineImpl engine, java.util.List<MyRoleMessageExchange> subscribers, MessageExchangeDAO mexDao, MyRoleMessageExchange template)
process
- subscribers
- mexId
- oplink
- template
- public java.util.concurrent.Future invoke(Message request)
invoke
in interface MyRoleMessageExchange
invoke
in class MyRoleMessageExchangeImpl
public EndpointReference getEndpointReference() throws BpelEngineException
getEndpointReference
in interface MessageExchange
BpelEngineException
- BpelEngineExceptionpublic Message getResponse()
getResponse
in interface MessageExchange
public MessageExchange.Status getStatus()
MessageExchange
getStatus
in interface MessageExchange
public MyRoleMessageExchange.CorrelationStatus getCorrelationStatus()
MyRoleMessageExchange
CorrelationType
for details).getCorrelationStatus
in interface MyRoleMessageExchange
getCorrelationStatus
in class MyRoleMessageExchangeImpl
public int getSubscriberCount()
public void setSubscriberCount(int subscriberCount)
public javax.wsdl.PortType getPortType()
MessageExchange
getPortType
in interface MessageExchange
null
if not available.public javax.wsdl.Operation getOperation()
MessageExchange
getOperation
in interface MessageExchange
null
if not availblepublic 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 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 Message getRequest()
MessageExchange
getRequest
in interface MessageExchange
public MessageExchangeDAO getDAO()
public Message createMessage(javax.xml.namespace.QName msgType)
MessageExchange
createMessage
in interface MessageExchange
msgType
- message typeMessage
public void setEndpointReference(EndpointReference ref)
public java.lang.String getProperty(java.lang.String key)
MessageExchange
getProperty
in interface MessageExchange
key
- property keypublic 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 void release()
MessageExchange
release
in interface MessageExchange