Modifier and Type | Method and Description |
---|---|
void |
AegisSchemaValidationInInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
static boolean |
AttachmentUtil.isMtomEnabled(Message message) |
Constructor and Description |
---|
AttachmentDeserializer(Message message) |
AttachmentDeserializer(Message message,
List<String> supportedTypes) |
AttachmentSerializer(Message messageParam) |
AttachmentSerializer(Message messageParam,
String multipartType,
Map<String,List<String>> headers) |
Modifier and Type | Method and Description |
---|---|
Message |
Binding.createMessage()
Create a Message for this Binding.
|
Message |
Binding.createMessage(Message m)
Create a Message form the message.
|
Modifier and Type | Method and Description |
---|---|
Message |
Binding.createMessage(Message m)
Create a Message form the message.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
ColocOutInterceptor.getInBoundMessage(Exchange ex) |
Modifier and Type | Method and Description |
---|---|
protected List<Interceptor<? extends Message>> |
ColocMessageObserver.addColocInterceptors() |
Modifier and Type | Method and Description |
---|---|
static void |
ColocUtil.convertObjectToSource(Message message) |
static void |
ColocUtil.convertSourceToObject(Message message) |
void |
ColocInInterceptor.handleMessage(Message msg) |
void |
ColocOutInterceptor.handleMessage(Message message) |
void |
WebFaultInInterceptor.handleMessage(Message message) |
protected void |
ColocOutInterceptor.invokeColocObserver(Message outMsg,
Endpoint inboundEndpoint) |
void |
ColocMessageObserver.onMessage(Message m) |
protected void |
ColocMessageObserver.setExchangeProperties(Exchange exchange,
Message m) |
Modifier and Type | Method and Description |
---|---|
BindingOperationInfo |
URIMapper.getOperation(String uri,
String verb,
Message m) |
Modifier and Type | Method and Description |
---|---|
void |
ContentTypeOutInterceptor.handleMessage(Message message) |
void |
DatabindingInSetupInterceptor.handleMessage(Message message) |
void |
DocumentWriterInterceptor.handleMessage(Message message) |
void |
URIParameterOutInterceptor.handleMessage(Message message) |
void |
DispatchInterceptor.handleMessage(Message message) |
void |
URIParameterInInterceptor.handleMessage(Message message) |
void |
DatabindingOutSetupInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
ObjectBinding.createMessage() |
Message |
ObjectBinding.createMessage(Message m) |
Modifier and Type | Method and Description |
---|---|
Message |
ObjectBinding.createMessage(Message m) |
void |
ObjectDispatchInInterceptor.handleMessage(Message message) |
void |
ObjectDispatchOutInterceptor.handleMessage(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
SoapMessage |
Modifier and Type | Method and Description |
---|---|
Message |
SoapBinding.createMessage() |
Message |
SoapBinding.createMessage(Message m) |
Modifier and Type | Method and Description |
---|---|
Message |
SoapBinding.createMessage(Message m) |
Constructor and Description |
---|
SoapMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
protected String |
RPCOutInterceptor.addOperationNode(NSStack nsStack,
Message message,
javax.xml.stream.XMLStreamWriter xmlWriter,
boolean output,
BindingOperationInfo boi) |
protected DataWriter<javax.xml.stream.XMLStreamWriter> |
SoapOutInterceptor.getDataWriter(Message message) |
static String |
SoapActionInInterceptor.getSoapAction(Message m) |
protected javax.xml.stream.XMLStreamWriter |
RPCOutInterceptor.getXMLStreamWriter(Message message) |
void |
RPCInInterceptor.handleMessage(Message message) |
void |
SoapHeaderInterceptor.handleMessage(Message m) |
void |
RPCOutInterceptor.handleMessage(Message message) |
protected Endpoint |
EndpointSelectionInterceptor.selectEndpoint(Message message,
Set<Endpoint> eps) |
Modifier and Type | Method and Description |
---|---|
Collection<PhaseInterceptor<? extends Message>> |
SAAJInInterceptor.getAdditionalInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
TCPConduit.assertMessage(Message message) |
void |
BackendTcpConduit.assertMessage(Message message) |
void |
TCPConduit.close(Message message) |
void |
BackendTcpConduit.close(Message msg) |
protected Conduit |
SoapTcpDestination.getInbuiltBackChannel(Message inMessage) |
void |
TCPConduit.prepare(Message message) |
void |
BackendTcpConduit.prepare(Message message) |
Constructor and Description |
---|
SoapTcpOutputStream(InputStream inStream,
OutputStream outStream,
Message message,
String targetWsURI,
MessageObserver incomingObserver) |
SoapTcpOutputStream(InputStream inStream,
OutputStream outStream,
Message message,
String targetWsURI,
MessageObserver incomingObserver,
int chunkSize) |
Modifier and Type | Method and Description |
---|---|
Message |
XMLBinding.createMessage() |
Message |
XMLBinding.createMessage(Message m) |
Modifier and Type | Method and Description |
---|---|
Message |
XMLBinding.createMessage(Message m) |
Constructor and Description |
---|
XMLMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
XMLFaultOutInterceptor.handleFault(Message message) |
void |
XMLMessageOutInterceptor.handleMessage(Message message) |
void |
XMLFaultInInterceptor.handleMessage(Message message) |
void |
XMLFaultOutInterceptor.handleMessage(Message message) |
void |
XMLMessageInInterceptor.handleMessage(Message message) |
protected boolean |
XMLFaultOutInterceptor.mustPropogateException(Message m) |
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
BusDefinitionParser.BusConfig.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
BusDefinitionParser.BusConfig.getInInterceptors() |
List<Interceptor<? extends Message>> |
BusDefinitionParser.BusConfig.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
BusDefinitionParser.BusConfig.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
BusDefinitionParser.BusConfig.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
BusDefinitionParser.BusConfig.setInInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
BusDefinitionParser.BusConfig.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
BusDefinitionParser.BusConfig.setOutInterceptors(List<Interceptor<? extends Message>> interceptors) |
Modifier and Type | Method and Description |
---|---|
void |
FailoverTargetSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
Conduit |
FailoverTargetSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
LoadDistributorTargetSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Modifier and Type | Method and Description |
---|---|
Message |
ContinuationInfo.getMessage() |
Constructor and Description |
---|
ContinuationInfo(Message m) |
Modifier and Type | Method and Description |
---|---|
void |
StaxDataBindingInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
protected Conduit |
AbstractConduitSelector.getSelectedConduit(Message message)
Mechanics to actually get the Conduit from the ConduitInitiator
if necessary.
|
protected void |
ClientImpl.modifyChain(InterceptorChain chain,
Message ctx,
boolean in) |
void |
ClientImpl.onMessage(Message message) |
void |
NullConduitSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
void |
UpfrontConduitSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
void |
PreexistingConduitSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
void |
DeferredConduitSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
void |
ConduitSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
protected void |
ClientImpl.prepareConduitSelector(Message message) |
protected Object[] |
ClientImpl.processResult(Message message,
Exchange exchange,
BindingOperationInfo oi,
Map<String,Object> resContext) |
protected void |
AbstractConduitSelector.replaceEndpointAddressPropertyIfNeeded(Message message,
String endpointAddress) |
Conduit |
NullConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
UpfrontConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
PreexistingConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
DeferredConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
ConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
protected void |
ClientImpl.setContext(Map<String,Object> ctx,
Message message) |
protected void |
ClientImpl.setOutMessageProperties(Message message,
BindingOperationInfo boi) |
protected void |
ClientImpl.setParameters(Object[] params,
Message message) |
void |
ClientCallback.start(Message msg)
Called when a message is first received prior to any actions
being applied to the message.
|
Modifier and Type | Method and Description |
---|---|
void |
WSDLGetInterceptor.handleMessage(Message message) |
protected void |
WSDLGetInterceptor.updateDoc(Document doc,
String base,
Map<String,javax.wsdl.Definition> mp,
Map<String,javax.wsdl.extensions.schema.SchemaReference> smp,
Message message) |
void |
WSDLGetInterceptor.writeResponse(Message message,
String base,
Map<String,String> params,
String ctxUri,
EndpointInfo endpointInfo,
OutputStream os) |
Modifier and Type | Interface and Description |
---|---|
interface |
Interceptor<T extends Message>
Base interface for all interceptors.
|
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getInFaultInterceptors()
Returns the list of interceptors attached to the incoming fault interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getInInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getInInterceptors()
Returns the list of interceptors attached to the incoming interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInInterceptors() |
ListIterator<Interceptor<? extends Message>> |
InterceptorChain.getIterator() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getOutFaultInterceptors()
Returns the list of interceptors attached to the outgoing fault interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getOutInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getOutInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getOutInterceptors()
Returns the list of interceptors attached to the outgoing interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
boolean |
InterceptorChain.doIntercept(Message message) |
boolean |
InterceptorChain.doInterceptStartingAfter(Message message,
String startingAfterInterceptorID) |
boolean |
InterceptorChain.doInterceptStartingAt(Message message,
String startingAtInterceptorID) |
protected MessagePartInfo |
AbstractInDatabindingInterceptor.findMessagePart(Exchange exchange,
Collection<OperationInfo> operations,
QName name,
boolean client,
int index,
Message message)
Find the next possible message part in the message.
|
protected static Conduit |
OutgoingChainInterceptor.getBackChannelConduit(Message message) |
protected DataReader<javax.xml.stream.XMLStreamReader> |
AbstractInDatabindingInterceptor.getDataReader(Message message) |
protected <T> DataReader<T> |
AbstractInDatabindingInterceptor.getDataReader(Message message,
Class<T> input) |
protected <T> DataWriter<T> |
AbstractOutDatabindingInterceptor.getDataWriter(Message message,
Service service,
Class<T> output) |
protected Object |
FaultOutInterceptor.getFaultBean(Throwable cause,
FaultInfo faultPart,
Message message) |
protected MessageInfo |
AbstractInDatabindingInterceptor.getMessageInfo(Message message,
BindingOperationInfo operation) |
protected MessageInfo |
AbstractInDatabindingInterceptor.getMessageInfo(Message message,
BindingOperationInfo operation,
boolean requestor) |
protected DataReader<Node> |
AbstractInDatabindingInterceptor.getNodeDataReader(Message message) |
protected String |
URIMappingInterceptor.getOperationName(Message message) |
protected MessageContentsList |
URIMappingInterceptor.getParameters(Message message,
BindingOperationInfo operation) |
protected Map<String,String> |
URIMappingInterceptor.getQueries(Message message) |
static javax.xml.stream.XMLInputFactory |
StaxInInterceptor.getXMLInputFactory(Message m) |
static javax.xml.stream.XMLOutputFactory |
StaxOutInterceptor.getXMLOutputFactory(Message m) |
protected DepthXMLStreamReader |
AbstractInDatabindingInterceptor.getXMLStreamReader(Message message) |
protected javax.xml.stream.XMLStreamWriter |
AbstractOutDatabindingInterceptor.getXMLStreamWriter(Message message) |
void |
AttachmentInInterceptor.handleFault(Message messageParam) |
void |
StaxOutInterceptor.handleFault(Message message) |
void |
OneWayProcessorInterceptor.handleFault(Message message) |
void |
FIStaxOutInterceptor.handleFault(Message message) |
void |
WrappedOutInterceptor.handleMessage(Message message) |
void |
WrappedOutInterceptor.WrappedOutEndingInterceptor.handleMessage(Message message) |
void |
LoggingOutInterceptor.handleMessage(Message message) |
void |
MessageSenderInterceptor.handleMessage(Message message) |
void |
MessageSenderInterceptor.MessageSenderEndingInterceptor.handleMessage(Message message) |
void |
AttachmentInInterceptor.handleMessage(Message message) |
void |
StaxOutInterceptor.handleMessage(Message message) |
void |
PrettyLoggingOutInterceptor.handleMessage(Message message)
Deprecated.
|
void |
OneWayProcessorInterceptor.handleMessage(Message message) |
void |
StaxOutEndingInterceptor.handleMessage(Message message) |
void |
LoggingInInterceptor.handleMessage(Message message) |
void |
StaxInInterceptor.handleMessage(Message message) |
void |
FIStaxOutInterceptor.handleMessage(Message message) |
void |
FaultOutInterceptor.handleMessage(Message message) |
void |
OutgoingChainInterceptor.handleMessage(Message message) |
void |
AttachmentOutInterceptor.handleMessage(Message message) |
void |
AttachmentOutInterceptor.AttachmentOutEndingInterceptor.handleMessage(Message message) |
void |
ClientFaultConverter.handleMessage(Message msg) |
void |
AbstractEndpointSelectionInterceptor.handleMessage(Message message) |
void |
BareOutInterceptor.handleMessage(Message message) |
void |
FIStaxInInterceptor.handleMessage(Message message) |
void |
WrappedInInterceptor.handleMessage(Message message) |
void |
URIMappingInterceptor.handleMessage(Message message) |
void |
BareInInterceptor.handleMessage(Message message) |
void |
ServiceInvokerInterceptor.handleMessage(Message message) |
void |
DocLiteralInInterceptor.handleMessage(Message message) |
protected boolean |
FIStaxInInterceptor.isHttpVerbSupported(Message message) |
protected boolean |
FIStaxInInterceptor.isRequestor(Message message) |
protected boolean |
AbstractInDatabindingInterceptor.isRequestor(Message message) |
protected boolean |
AbstractOutDatabindingInterceptor.isRequestor(Message message) |
protected void |
LoggingInInterceptor.logging(Message message) |
void |
AbstractFaultChainInitiatorObserver.onMessage(Message message) |
void |
ClientOutFaultObserver.onMessage(Message m)
override the super class method
|
protected void |
ClientFaultConverter.processFaultDetail(Fault fault,
Message msg) |
protected abstract Endpoint |
AbstractEndpointSelectionInterceptor.selectEndpoint(Message message,
Set<Endpoint> eps)
Select an Endpoint which will be used for the rest of the invocation.
|
protected MessageInfo |
AbstractInDatabindingInterceptor.setMessage(Message message,
BindingOperationInfo operation,
boolean requestor,
ServiceInfo si,
MessageInfo msgInfo) |
protected boolean |
AbstractOutDatabindingInterceptor.shouldValidate(Message m) |
protected boolean |
DocLiteralInInterceptor.shouldWrapParameters(MessageInfo msgInfo,
Message message) |
protected boolean |
AbstractInDatabindingInterceptor.supportsDataReader(Message message,
Class<?> input) |
protected void |
AbstractOutDatabindingInterceptor.writeParts(Message message,
Exchange exchange,
BindingOperationInfo operation,
MessageContentsList objs,
List<MessagePartInfo> parts) |
protected boolean |
AbstractOutDatabindingInterceptor.writeToOutputStream(Message m,
BindingInfo info,
Service s) |
Modifier and Type | Method and Description |
---|---|
void |
InterceptorChain.add(Collection<Interceptor<? extends Message>> i)
Adds multiple interceptors to the interceptor chain.
|
void |
InterceptorChain.add(Interceptor<? extends Message> i)
Adds a single interceptor to the interceptor chain.
|
void |
InterceptorChain.remove(Interceptor<? extends Message> i) |
void |
AbstractBasicInterceptorProvider.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractAttributedInterceptorProvider.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractBasicInterceptorProvider.setInInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractAttributedInterceptorProvider.setInInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractBasicInterceptorProvider.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractAttributedInterceptorProvider.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractBasicInterceptorProvider.setOutInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractAttributedInterceptorProvider.setOutInterceptors(List<Interceptor<? extends Message>> interceptors) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
DepthRestrictingStreamInterceptor.canBeIgnored(Message message) |
protected Method |
AbstractAuthorizingInInterceptor.getTargetMethod(Message m) |
void |
AbstractSecurityContextInInterceptor.handleMessage(Message message) |
void |
DepthRestrictingStreamInterceptor.handleMessage(Message message) |
void |
JAASLoginInterceptor.handleMessage(Message message) |
void |
AbstractAuthorizingInInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
TransformOutInterceptor.handleFault(Message message) |
void |
TransformInInterceptor.handleMessage(Message message) |
void |
TransformOutInterceptor.handleMessage(Message message) |
protected boolean |
TransformOutInterceptor.isHttpVerbSupported(Message message) |
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
JAXBDataBinding.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
JAXBDataBinding.getInInterceptors() |
List<Interceptor<? extends Message>> |
JAXBDataBinding.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
JAXBDataBinding.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
JAXBAttachmentSchemaValidationHack.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
EndpointImpl.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
EndpointImpl.getInInterceptors() |
List<Interceptor<? extends Message>> |
EndpointImpl.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
EndpointImpl.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
EndpointImpl.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
EndpointImpl.setInInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
EndpointImpl.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
EndpointImpl.setOutInterceptors(List<Interceptor<? extends Message>> interceptors) |
Modifier and Type | Method and Description |
---|---|
Message |
WrappedMessageContext.getWrappedMessage() |
Constructor and Description |
---|
WrappedMessageContext(Message m) |
WrappedMessageContext(Message m,
javax.xml.ws.handler.MessageContext.Scope defScope) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJAXWSHandlerInterceptor<T extends Message> |
class |
AbstractProtocolHandlerInterceptor<T extends Message> |
Modifier and Type | Method and Description |
---|---|
void |
HandlerChainInvoker.mepComplete(Message message)
Invoke handlers at the end of an MEP calling close on each.
|
Modifier and Type | Method and Description |
---|---|
void |
LogicalHandlerOutInterceptor.handleFault(Message message) |
void |
LogicalHandlerFaultInInterceptor.handleFault(Message message) |
void |
LogicalHandlerInInterceptor.handleFault(Message message) |
void |
LogicalHandlerOutInterceptor.handleMessage(Message message) |
void |
LogicalHandlerFaultInInterceptor.handleMessage(Message message) |
void |
LogicalHandlerInInterceptor.handleMessage(Message message) |
void |
LogicalHandlerFaultOutInterceptor.handleMessage(Message message) |
Constructor and Description |
---|
LogicalMessageContextImpl(Message wrapped) |
Constructor and Description |
---|
SOAPMessageContextImpl(Message m) |
Modifier and Type | Method and Description |
---|---|
void |
WrapperClassInInterceptor.handleMessage(Message message) |
void |
WebFaultOutInterceptor.handleMessage(Message message) |
void |
HolderOutInterceptor.handleMessage(Message message) |
void |
MessageModeOutInterceptor.handleMessage(Message message) |
void |
WrapperClassOutInterceptor.handleMessage(Message message) |
void |
HolderInInterceptor.handleMessage(Message message) |
void |
MessageModeInInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
boolean |
FaultListener.faultOccurred(Exception exception,
String description,
Message message)
Handle the occurred exception.
|
Modifier and Type | Method and Description |
---|---|
void |
ResponseTimeMessageInvokerInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageInInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageOutInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageOutInterceptor.EndingInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageInvokerInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageInInterceptor.handleMessage(Message message) |
void |
PersistOutInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageOutInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageOutInterceptor.EndingInterceptor.handleMessage(Message message) |
void |
PersistInInterceptor.handleMessage(Message message) |
protected boolean |
AbstractMessageResponseTimeInterceptor.isClient(Message msg) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWrappedMessage
A base class to build your own message implementations on.
|
class |
MessageImpl |
class |
XMLMessage |
Modifier and Type | Method and Description |
---|---|
Message |
ExchangeImpl.getInFaultMessage() |
Message |
Exchange.getInFaultMessage() |
Message |
ExchangeImpl.getInMessage() |
Message |
Exchange.getInMessage()
Returns the inbound message for the exchange.
|
Message |
AbstractWrappedMessage.getMessage() |
Message |
ExchangeImpl.getOutFaultMessage() |
Message |
Exchange.getOutFaultMessage() |
Message |
ExchangeImpl.getOutMessage() |
Message |
Exchange.getOutMessage()
Returns the outbound message for the exchange.
|
Modifier and Type | Method and Description |
---|---|
static void |
MessageImpl.copyContent(Message m1,
Message m2) |
Conduit |
ExchangeImpl.getConduit(Message message) |
Conduit |
Exchange.getConduit(Message message) |
static MessageContentsList |
MessageContentsList.getContentsList(Message msg) |
static boolean |
MessageUtils.getContextualBoolean(Message m,
String key,
boolean defaultValue) |
static FaultMode |
MessageUtils.getFaultMode(Message message)
Determine the fault mode for the underlying (fault) message
(for use on server side only).
|
static boolean |
MessageUtils.isDOMPresent(Message m)
Returns true if the underlying content format is a W3C DOM or a SAAJ message.
|
static boolean |
MessageUtils.isFault(Message message)
Determine if message is fault.
|
static boolean |
MessageUtils.isOutbound(Message message)
Determine if message is outbound.
|
static boolean |
MessageUtils.isPartialResponse(Message message)
Determine if the current message is a partial response.
|
static boolean |
MessageUtils.isRequestor(Message message)
Determine if current messaging role is that of requestor.
|
void |
ExchangeImpl.setInFaultMessage(Message m) |
void |
Exchange.setInFaultMessage(Message m) |
void |
ExchangeImpl.setInMessage(Message m) |
void |
Exchange.setInMessage(Message m) |
void |
AbstractWrappedMessage.setMessage(Message message) |
void |
ExchangeImpl.setOutFaultMessage(Message m) |
void |
Exchange.setOutFaultMessage(Message m) |
void |
ExchangeImpl.setOutMessage(Message m) |
void |
Exchange.setOutMessage(Message m) |
Constructor and Description |
---|
AbstractWrappedMessage(Message msg) |
MessageImpl(Message m) |
XMLMessage(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPhaseInterceptor<T extends Message>
Provides a starting point implementation for a interceptors that
participate in phased message processing.
|
interface |
PhaseInterceptor<T extends Message>
A phase interceptor is an intercetor that participates in a
PhaseInterceptorChain.
|
Modifier and Type | Method and Description |
---|---|
static Message |
PhaseInterceptorChain.getCurrentMessage() |
Modifier and Type | Method and Description |
---|---|
Collection<PhaseInterceptor<? extends Message>> |
PhaseInterceptor.getAdditionalInterceptors()
Returns a collection of Interceptors that should be added to the chain
whenever this interceptor is added.
|
Collection<PhaseInterceptor<? extends Message>> |
AbstractPhaseInterceptor.getAdditionalInterceptors() |
ListIterator<Interceptor<? extends Message>> |
PhaseInterceptorChain.getIterator() |
Iterator<Interceptor<? extends Message>> |
PhaseInterceptorChain.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
PhaseInterceptorChain.doIntercept(Message message)
Intercept a message, invoking each phase's handlers in turn.
|
boolean |
PhaseInterceptorChain.doInterceptStartingAfter(Message message,
String startingAfterInterceptorID)
Intercept a message, invoking each phase's handlers in turn,
starting after the specified interceptor.
|
boolean |
PhaseInterceptorChain.doInterceptStartingAt(Message message,
String startingAtInterceptorID)
Intercept a message, invoking each phase's handlers in turn,
starting at the specified interceptor.
|
void |
PhaseInterceptorChain.unwind(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
TestUtilities.TestMessageObserver.onMessage(Message message) |
Modifier and Type | Field and Description |
---|---|
protected List<Interceptor<? extends Message>> |
MultipleEndpointObserver.bindingInterceptors |
protected List<Interceptor<? extends Message>> |
MultipleEndpointObserver.routingInterceptors |
Modifier and Type | Method and Description |
---|---|
protected Message |
MultipleEndpointObserver.createMessage(Message message)
Give a chance for a Binding to customize their message
|
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
MultipleEndpointObserver.getBindingInterceptors() |
List<Interceptor<? extends Message>> |
MultipleEndpointObserver.getRoutingInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractConduit.close(Message msg) |
void |
Conduit.close(Message message)
Close the connections associated with the message
|
protected Message |
MultipleEndpointObserver.createMessage(Message message)
Give a chance for a Binding to customize their message
|
Conduit |
AbstractDestination.getBackChannel(Message inMessage,
Message partialResponse,
EndpointReferenceType address)
Retreive a back-channel Conduit, which must be policy-compatible
with the current Message and associated Destination.
|
Conduit |
Destination.getBackChannel(Message inMessage,
Message unused1,
EndpointReferenceType unused2)
Retreive a back-channel Conduit, which must be policy-compatible
with the current Message and associated Destination.
|
protected abstract Conduit |
AbstractDestination.getInbuiltBackChannel(Message inMessage) |
void |
MultipleEndpointObserver.onMessage(Message message) |
void |
ChainInitiationObserver.onMessage(Message m) |
void |
MessageObserver.onMessage(Message message)
Called for an incoming message, i.e.
|
void |
Conduit.prepare(Message message)
Prepare the message for sending.
|
protected void |
MultipleEndpointObserver.setExchangeProperties(Exchange exchange,
Message m) |
protected void |
ChainInitiationObserver.setExchangeProperties(Exchange exchange,
Message m) |
Modifier and Type | Method and Description |
---|---|
void |
GZIPOutInterceptor.handleMessage(Message message) |
void |
GZIPInInterceptor.handleMessage(Message message) |
Modifier and Type | Field and Description |
---|---|
protected Message |
HTTPConduit.WrappedOutputStream.outMessage |
Modifier and Type | Method and Description |
---|---|
protected Message |
AbstractHTTPDestination.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req) |
protected Message |
AbstractHTTPDestination.retrieveFromServlet3Async(javax.servlet.http.HttpServletRequest req) |
Modifier and Type | Method and Description |
---|---|
void |
HTTPConduit.assertMessage(Message message) |
void |
AbstractHTTPDestination.assertMessage(Message message) |
void |
HTTPConduit.close(Message msg) |
void |
AbstractHTTPDestination.BackChannelConduit.close(Message msg) |
protected OutputStream |
HTTPConduit.createOutputStream(Message message,
HttpURLConnection connection,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
abstract void |
MessageTrustDecider.establishTrust(String conduitName,
URLConnectionInfo connectionInfo,
Message message)
This method is called when a Message is about to be sent out
over an HTTPConduit.
|
protected OutputStream |
AbstractHTTPDestination.flushHeaders(Message outMessage) |
protected OutputStream |
AbstractHTTPDestination.flushHeaders(Message outMessage,
boolean getStream) |
HTTPClientPolicy |
HTTPConduit.getClient(Message message) |
AuthorizationPolicy |
HTTPConduit.getEffectiveAuthPolicy(Message message)
Determines effective auth policy from message, conduit and empty default
with priority from first to last
|
protected Conduit |
AbstractHTTPDestination.getInbuiltBackChannel(Message inMessage) |
static Map<String,List<String>> |
Headers.getSetProtocolHeaders(Message message)
While extracting the Message.PROTOCOL_HEADERS property from the Message,
this call ensures that the Message.PROTOCOL_HEADERS property is
set on the Message.
|
protected boolean |
HTTPConduit.isChunkingSupported(Message message,
String httpMethod) |
protected boolean |
AbstractHTTPDestination.isOneWay(Message message) |
void |
HTTPConduit.InterposedMessageObserver.onMessage(Message inMessage)
Called for an incoming message.
|
void |
HTTPConduit.prepare(Message message)
Prepare to send an outbound HTTP message over this http conduit to a
particular endpoint.
|
void |
AbstractHTTPDestination.BackChannelConduit.prepare(Message message)
Send an outbound message, assumed to contain all the name-value
mappings of the corresponding input message (if any).
|
protected void |
AbstractHTTPDestination.setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
protected void |
AbstractHTTPDestination.setupMessage(Message inMessage,
javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
protected void |
AbstractHTTPDestination.setupMessage(Message inMessage,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
void |
Cookies.writeToMessageHeaders(Message message) |
Constructor and Description |
---|
Headers(Message message) |
HTTPConduit.WrappedOutputStream(Message outMessage,
HttpURLConnection connection,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName) |
Servlet3ContinuationProvider(javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message inMessage) |
Modifier and Type | Method and Description |
---|---|
String |
DigestAuthSupplier.getAuthorization(AuthorizationPolicy authPolicy,
URL currentURL,
Message message,
String fullHeader) |
String |
HttpAuthSupplier.getAuthorization(AuthorizationPolicy authPolicy,
URL url,
Message message,
String fullHeader)
The HTTPConduit makes a call to this method to obtain
an Authentication token for http authentication.
|
String |
SpnegoAuthSupplier.getAuthorization(AuthorizationPolicy authPolicy,
URL currentURL,
Message message,
String fullHeader) |
String |
DefaultBasicAuthSupplier.getAuthorization(AuthorizationPolicy authPolicy,
URL currentURL,
Message message,
String fullHeader) |
Modifier and Type | Method and Description |
---|---|
static void |
PolicyUtils.assertClientPolicy(Message message,
HTTPClientPolicy client)
Asserts all HTTPClientPolicy assertions that are compatible with the specified
client policy.
|
static void |
PolicyUtils.assertServerPolicy(Message message,
HTTPServerPolicy server)
Asserts all HTTPServerPolicy assertions that are equal to the specified
server policy.
|
static HTTPClientPolicy |
PolicyUtils.getClient(Message message,
HTTPClientPolicy confPolicy)
Returns a HTTPClientPolicy that is compatible with the assertions included in the
service, endpoint, operation and message policy subjects AND the HTTPClientPolicy
passed as a second argument.
|
static HTTPServerPolicy |
PolicyUtils.getServer(Message message,
HTTPServerPolicy confPolicy)
Returns a HTTPServerPolicy that is compatible with the assertions included in the
service, endpoint, operation and message policy subjects AND the HTTPServerPolicy
passed as a second argument.
|
Modifier and Type | Method and Description |
---|---|
void |
CertConstraintsInterceptor.handleMessage(Message message) |
static void |
SSLUtils.propogateSecureSession(javax.servlet.http.HttpServletRequest request,
Message message)
Propogate in the message a TLSSessionInfo instance representative
of the TLS-specific information in the HTTP request.
|
Modifier and Type | Field and Description |
---|---|
protected Message |
JMSDestination.BackChannelConduit.inMessage |
Modifier and Type | Method and Description |
---|---|
static void |
JMSUtils.addContentTypeToProtocolHeader(Message message) |
static javax.jms.Message |
JMSUtils.buildJMSMessageFromCXFMessage(JMSConfiguration jmsConfig,
Message outMessage,
Object payload,
String messageType,
javax.jms.Session session,
javax.jms.Destination replyTo,
String correlationId) |
static String |
JMSUtils.getContentEncoding(Message message) |
static String |
JMSUtils.getContentType(Message message) |
protected Conduit |
JMSDestination.getInbuiltBackChannel(Message inMessage) |
javax.jms.Destination |
JMSDestination.getReplyToDestination(org.springframework.jms.core.JmsTemplate jmsTemplate,
Message inMessage) |
protected static boolean |
JMSConduit.isSetReplyTo(Message message) |
static void |
JMSUtils.populateIncomingContext(javax.jms.Message message,
Message inMessage,
String messageType,
JMSConfiguration jmsConfig) |
void |
JMSDestination.BackChannelConduit.prepare(Message message)
Send an outbound message, assumed to contain all the name-value mappings of the corresponding input
message (if any).
|
void |
JMSConduit.prepare(Message message)
Prepare the message to be sent.
|
static void |
JMSUtils.retrieveAndSetPayload(Message inMessage,
javax.jms.Message message,
String encoding)
Extract the payload of an incoming message.
|
Constructor and Description |
---|
JMSContinuation(Bus b,
Message m,
MessageObserver observer,
Collection<JMSContinuation> cList,
org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener,
JMSConfiguration jmsConfig) |
JMSContinuationProvider(Bus b,
Message m,
MessageObserver observer,
Collection<JMSContinuation> cList,
org.springframework.jms.listener.AbstractMessageListenerContainer jmsListener,
JMSConfiguration jmsConfig) |
Modifier and Type | Method and Description |
---|---|
void |
LocalConduit.close(Message message) |
void |
LocalTransportFactory.copy(Message message,
Message copy) |
protected Conduit |
LocalDestination.getInbuiltBackChannel(Message inMessage) |
void |
LocalConduit.prepare(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
ContextUtils.createMessage(Exchange exchange)
Create a Binding specific Message.
|
Modifier and Type | Method and Description |
---|---|
static AttributedURIType |
ContextUtils.getAction(Message message)
Construct the Action URI.
|
protected String |
MAPAggregator.getActionUri(Message message,
boolean checkMessage) |
static Conduit |
ContextUtils.getConduit(Conduit conduit,
Message message)
Retreive Conduit from Exchange if not already available
|
void |
MAPAggregator.handleFault(Message message)
Invoked when unwinding normal interceptor chain when a fault occurred.
|
void |
MAPAggregator.handleMessage(Message message)
Invoked for normal processing of inbound and outbound messages.
|
static boolean |
ContextUtils.isFault(Message message)
Determine if message is fault.
|
static boolean |
ContextUtils.isOutbound(Message message)
Determine if message is outbound.
|
static boolean |
ContextUtils.isRequestor(Message message)
Determine if current messaging role is that of requestor.
|
protected boolean |
MAPAggregator.mediate(Message message,
boolean isFault)
Mediate message flow.
|
void |
MAPAggregator.InterposedMessageObserver.onMessage(Message inMessage)
Called for an incoming message.
|
static void |
ContextUtils.rebaseResponse(EndpointReferenceType reference,
AddressingProperties inMAPs,
Message inMessage)
Rebase response on replyTo
|
static boolean |
ContextUtils.retrieveAsyncPostResponseDispatch(Message message)
Retrieve indication that an async post-response service invocation
is required.
|
static boolean |
ContextUtils.retrieveDeferredUncorrelatedMessageAbort(Message message)
Retrieve indication that a deferred uncorrelated message abort should
occur.
|
static boolean |
ContextUtils.retrieveDeferUncorrelatedMessageAbort(Message message)
Retrieve indication that a deferred uncorrelated message abort is
supported
|
static String |
ContextUtils.retrieveMAPFaultName(Message message)
Retrieve MAP fault name from the message.
|
static String |
ContextUtils.retrieveMAPFaultReason(Message message)
Retrieve MAP fault reason from the message.
|
static AddressingPropertiesImpl |
ContextUtils.retrieveMAPs(Message message,
boolean isProviderContext,
boolean isOutbound) |
static AddressingPropertiesImpl |
ContextUtils.retrieveMAPs(Message message,
boolean isProviderContext,
boolean isOutbound,
boolean warnIfMissing) |
static boolean |
ContextUtils.retrievePartialResponseSent(Message message)
Retrieve indication that a partial response has been sent.
|
static EndpointReferenceType |
WSAContextUtils.retrieveTo(Conduit conduit,
Message message)
Retrieve To EPR from the context.
|
static boolean |
WSAContextUtils.retrieveUsingAddressing(Message message)
Retrieve UsingAddressing override flag from the context
|
static void |
ContextUtils.storeDeferredUncorrelatedMessageAbort(Message message)
Store indication that a deferred uncorrelated message abort should
occur
|
static void |
ContextUtils.storeDeferUncorrelatedMessageAbort(Message message)
Store indication that a deferred uncorrelated message abort is
supported
|
static void |
ContextUtils.storeMAPFaultName(String faultName,
Message message)
Store bad MAP fault name in the message.
|
static void |
ContextUtils.storeMAPFaultReason(String reason,
Message message)
Store MAP fault reason in the message.
|
static void |
ContextUtils.storeMAPs(AddressingProperties maps,
Message message,
boolean isOutbound)
Store MAPs in the message.
|
static void |
ContextUtils.storeMAPs(AddressingProperties maps,
Message message,
boolean isOutbound,
boolean isRequestor)
Store MAPs in the message.
|
static void |
ContextUtils.storeMAPs(AddressingProperties maps,
Message message,
boolean isOutbound,
boolean isRequestor,
boolean isProviderContext)
Store MAPs in the message.
|
static void |
ContextUtils.storePartialResponseSent(Message message)
Store an indication that a partial response has been sent.
|
static void |
WSAContextUtils.storeTo(EndpointReferenceType to,
Message message)
Store To EPR in the context
|
static void |
WSAContextUtils.storeUsingAddressing(boolean override,
Message message)
Store UsingAddressing override flag in the context
|
Modifier and Type | Field and Description |
---|---|
protected List<Interceptor<? extends Message>> |
EffectivePolicyImpl.interceptors |
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
EndpointPolicyImpl.getFaultInterceptors() |
List<Interceptor<? extends Message>> |
EndpointPolicy.getFaultInterceptors() |
List<Interceptor<? extends Message>> |
EndpointPolicyImpl.getInterceptors() |
List<Interceptor<? extends Message>> |
EffectivePolicyImpl.getInterceptors() |
List<Interceptor<? extends Message>> |
EffectivePolicy.getInterceptors() |
List<Interceptor<? extends Message>> |
EndpointPolicy.getInterceptors() |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getInterceptors(Collection<? extends org.apache.neethi.Assertion> alternative,
boolean out,
boolean fault) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getInterceptors(Collection<? extends org.apache.neethi.Assertion> alterative,
boolean out,
boolean fault) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideInFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideInFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideInInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideInInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideOutFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideOutFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideOutInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideOutInterceptors(Message m) |
Modifier and Type | Method and Description |
---|---|
void |
Assertor.assertMessage(Message message) |
protected BindingFaultInfo |
AbstractPolicyInterceptor.getBindingFaultInfo(Message msg,
Exception ex,
BindingOperationInfo boi) |
protected void |
AbstractPolicyInterceptor.getTransportAssertions(Message message) |
protected void |
ServerPolicyOutFaultInterceptor.handle(Message msg) |
protected void |
PolicyOutInterceptor.handle(Message msg) |
protected void |
PolicyVerificationInFaultInterceptor.handle(Message message)
Determines the effective policy, and checks if one of its alternatives
is supported.
|
protected void |
ClientPolicyInFaultInterceptor.handle(Message msg) |
protected void |
PolicyVerificationOutInterceptor.handle(Message message)
Checks if all assertions in the chosen alternative have been asserted.
|
protected void |
PolicyInInterceptor.handle(Message msg) |
protected void |
PolicyVerificationInInterceptor.handle(Message message)
Determines the effective policy, and checks if one of its alternatives
is supported.
|
protected abstract void |
AbstractPolicyInterceptor.handle(Message message) |
void |
AbstractPolicyInterceptor.handleMessage(Message message) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideInFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideInFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideInInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideInInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideOutFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideOutFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProvider.provideOutInterceptors(Message m) |
List<Interceptor<? extends Message>> |
AbstractPolicyInterceptorProvider.provideOutInterceptors(Message m) |
Modifier and Type | Method and Description |
---|---|
void |
MTOMPolicyInterceptor.handleMessage(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRMInterceptor<T extends Message>
Interceptor responsible for implementing exchange of RM protocol messages,
aggregating RM metadata in the application message and processing of
RM metadata contained in incoming application messages.
|
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
WrappedService.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
WrappedEndpoint.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
WrappedService.getInInterceptors() |
List<Interceptor<? extends Message>> |
WrappedEndpoint.getInInterceptors() |
List<Interceptor<? extends Message>> |
WrappedService.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
WrappedEndpoint.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
WrappedService.getOutInterceptors() |
List<Interceptor<? extends Message>> |
WrappedEndpoint.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
Destination.acknowledge(Message message)
Acknowledges receipt of a message.
|
void |
DestinationSequence.acknowledge(Message message) |
void |
RetransmissionQueue.addUnacknowledged(Message message)
Accepts a new context for posible future retransmission.
|
static WriteOnCloseOutputStream |
RMUtils.createCachedStream(Message message,
OutputStream os) |
Destination |
RMManager.getDestination(Message message) |
RMEndpoint |
RMManager.getReliableEndpoint(Message message) |
SourceSequence |
RMManager.getSequence(Identifier inSeqId,
Message message,
AddressingProperties maps) |
Source |
RMManager.getSource(Message message) |
void |
RMDeliveryInterceptor.handle(Message message) |
protected void |
RMOutInterceptor.handle(Message message) |
protected void |
RMCaptureInInterceptor.handle(Message message) |
protected abstract void |
AbstractRMInterceptor.handle(Message message) |
protected void |
RMInInterceptor.handle(Message message) |
void |
RetransmissionInterceptor.handleFault(Message message) |
void |
RMInInterceptor.handleFault(Message message) |
void |
RetransmissionInterceptor.handleMessage(Message message) |
void |
AbstractRMInterceptor.handleMessage(Message msg) |
static boolean |
RMContextUtils.isServerSide(Message message)
Determine if message is currently being processed on server side.
|
static AddressingPropertiesImpl |
RMContextUtils.retrieveMAPs(Message message,
boolean isProviderContext,
boolean isOutbound)
Retrieves the addressing properties from the current message.
|
static RMProperties |
RMContextUtils.retrieveRMProperties(Message message,
boolean outbound)
Retrieve the RM properties from the current message.
|
static void |
RMContextUtils.storeMAPs(AddressingProperties maps,
Message message,
boolean isOutbound,
boolean isRequestor)
Store MAPs in the message.
|
static void |
RMContextUtils.storeRMProperties(Message message,
RMProperties rmps,
boolean outbound)
Store the RM properties in the current message.
|
void |
Servant.terminateSequence(Message message) |
Modifier and Type | Method and Description |
---|---|
static RMAssertion |
PolicyUtils.getRMAssertion(RMAssertion defaultValue,
Message message)
Returns an RMAssertion that is compatible with the default value
and all RMAssertions pertaining to the message (can never be null).
|
Modifier and Type | Method and Description |
---|---|
protected Message |
RetransmissionQueueImpl.ResendCandidate.getMessage() |
Modifier and Type | Method and Description |
---|---|
void |
RetransmissionQueueImpl.addUnacknowledged(Message message) |
protected RetransmissionQueueImpl.ResendCandidate |
RetransmissionQueueImpl.cacheUnacknowledged(Message message)
Accepts a new resend candidate.
|
protected RetransmissionQueueImpl.ResendCandidate |
RetransmissionQueueImpl.createResendCandidate(Message message) |
void |
RetransmissionQueueImpl.Resender.resend(Message message,
boolean requestAcknowledge)
Resend mechanics.
|
Constructor and Description |
---|
RetransmissionQueueImpl.ResendCandidate(Message m) |
Apache CXF