Modifier and Type | Method and Description |
---|---|
void |
AttachmentDataSource.cache(Message message) |
void |
AttachmentDataSource.hold(Message message) |
static boolean |
AttachmentUtil.isMtomEnabled(Message message) |
static void |
AttachmentUtil.setStreamedAttachmentProperties(Message message,
CachedOutputStream bos) |
Constructor and Description |
---|
AttachmentDeserializer(Message message) |
AttachmentDeserializer(Message message,
List<String> supportedTypes) |
AttachmentSerializer(Message messageParam) |
AttachmentSerializer(Message messageParam,
String multipartType,
boolean writeOptionalTypeParameters,
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 |
---|---|
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 |
---|---|
static Integer |
PropertyUtils.getInteger(Message message,
String key) |
static Long |
PropertyUtils.getLong(Message message,
String key) |
Modifier and Type | Field and Description |
---|---|
protected ModCountCopyOnWriteArrayList<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.inFaultInterceptors |
protected ModCountCopyOnWriteArrayList<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.inInterceptors |
protected ModCountCopyOnWriteArrayList<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.outFaultInterceptors |
protected ModCountCopyOnWriteArrayList<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.outInterceptors |
Modifier and Type | Method and Description |
---|---|
List<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractInterceptorProvidingDataBinding.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
StaxDataBindingInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
protected Conduit |
AbstractConduitSelector.createConduit(Message message,
Exchange exchange,
ConduitInitiator conduitInitiator) |
protected Conduit |
AbstractConduitSelector.findCompatibleConduit(Message message)
If address protocol was changed, conduit should be re-initialised
|
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 |
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 |
NullConduitSelector.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 boolean |
AbstractConduitSelector.replaceEndpointAddressPropertyIfNeeded(Message message,
String endpointAddress,
Conduit cond) |
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 |
NullConduitSelector.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 |
---|---|
protected boolean |
AbstractXSLTInterceptor.checkContextProperty(Message message) |
void |
XSLTOutInterceptor.handleMessage(Message message) |
void |
XSLTInInterceptor.handleMessage(Message message) |
protected void |
XSLTInInterceptor.transformIS(Message message,
InputStream is) |
protected void |
XSLTOutInterceptor.transformOS(Message message,
OutputStream out) |
protected void |
XSLTInInterceptor.transformReader(Message message,
Reader reader) |
protected void |
XSLTOutInterceptor.transformWriter(Message message,
Writer writer) |
protected void |
XSLTInInterceptor.transformXReader(Message message,
XMLStreamReader xReader) |
protected void |
XSLTOutInterceptor.transformXWriter(Message message,
XMLStreamWriter xWriter) |
Modifier and Type | Method and Description |
---|---|
static SchemaValidation.SchemaValidationType |
ServiceUtils.getSchemaValidationType(Message message)
A convenience method to check for schema validation config in the message context, and then in the service model.
|
static boolean |
ServiceUtils.isSchemaValidationEnabled(SchemaValidation.SchemaValidationType type,
Message message)
A short cut method to be able to test for if Schema Validation should be enabled
for IN or OUT without having to check BOTH and IN or OUT.
|
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>> |
InterceptorProvider.getInFaultInterceptors()
Returns the list of interceptors attached to the incoming fault interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getInInterceptors()
Returns the list of interceptors attached to the incoming interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInInterceptors() |
ListIterator<Interceptor<? extends Message>> |
InterceptorChain.getIterator() |
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>> |
AnnotationInterceptors.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
InterceptorProvider.getOutInterceptors()
Returns the list of interceptors attached to the outgoing interceptor
chain of the object.
|
List<Interceptor<? extends Message>> |
AnnotationInterceptors.getOutInterceptors() |
List<Interceptor<? extends Message>> |
AbstractBasicInterceptorProvider.getOutInterceptors() |
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) |
static Conduit |
MessageSenderInterceptor.getConduit(Message message) |
protected DataReader<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) |
static XMLInputFactory |
StaxInInterceptor.getXMLInputFactory(Message m) |
static XMLOutputFactory |
StaxOutInterceptor.getXMLOutputFactory(Message m) |
protected DepthXMLStreamReader |
AbstractInDatabindingInterceptor.getXMLStreamReader(Message message) |
protected XMLStreamWriter |
AbstractOutDatabindingInterceptor.getXMLStreamWriter(Message message) |
void |
StaxOutInterceptor.handleFault(Message message) |
void |
OneWayProcessorInterceptor.handleFault(Message message) |
void |
FIStaxOutInterceptor.handleFault(Message message) |
void |
AttachmentInInterceptor.handleFault(Message messageParam) |
void |
StaxOutInterceptor.handleMessage(Message message) |
void |
StaxOutEndingInterceptor.handleMessage(Message message) |
void |
StaxInInterceptor.handleMessage(Message message) |
void |
StaxInEndingInterceptor.handleMessage(Message message) |
void |
ServiceInvokerInterceptor.handleMessage(Message message) |
void |
OutgoingChainInterceptor.handleMessage(Message message) |
void |
OneWayProcessorInterceptor.handleMessage(Message message) |
void |
MessageSenderInterceptor.handleMessage(Message message) |
void |
MessageSenderInterceptor.MessageSenderEndingInterceptor.handleMessage(Message message) |
void |
LoggingOutInterceptor.handleMessage(Message message) |
void |
LoggingInInterceptor.handleMessage(Message message) |
void |
FaultOutInterceptor.handleMessage(Message message) |
void |
FIStaxOutInterceptor.handleMessage(Message message) |
void |
FIStaxInInterceptor.handleMessage(Message message) |
void |
ClientFaultConverter.handleMessage(Message msg) |
void |
AttachmentOutInterceptor.handleMessage(Message message) |
void |
AttachmentOutInterceptor.AttachmentOutEndingInterceptor.handleMessage(Message message) |
void |
AttachmentInInterceptor.handleMessage(Message message) |
protected boolean |
FIStaxInInterceptor.isHttpVerbSupported(Message message) |
protected static boolean |
AbstractLoggingInterceptor.isLoggingDisabledNow(Message message) |
protected boolean |
FIStaxInInterceptor.isRequestor(Message message) |
protected void |
LoggingInInterceptor.logging(Logger logger,
Message message) |
protected void |
LoggingInInterceptor.logInputStream(Message message,
InputStream is,
LoggingMessage buffer,
String encoding,
String ct) |
protected void |
LoggingInInterceptor.logReader(Message message,
Reader reader,
LoggingMessage buffer) |
void |
ClientOutFaultObserver.onMessage(Message m)
override the super class method
|
void |
AbstractFaultChainInitiatorObserver.onMessage(Message message) |
protected void |
ClientFaultConverter.processFaultDetail(Fault fault,
Message msg) |
protected void |
AbstractInDatabindingInterceptor.setDataReaderValidation(Service service,
Message message,
DataReader<?> reader)
Based on the Schema Validation configuration, will initialise the
DataReader with or without the schema set.
|
protected MessageInfo |
AbstractInDatabindingInterceptor.setMessage(Message message,
BindingOperationInfo operation,
boolean requestor,
ServiceInfo si,
MessageInfo msgInfo) |
protected void |
AbstractOutDatabindingInterceptor.setOperationSchemaValidation(Message message) |
protected void |
AbstractInDatabindingInterceptor.setOperationSchemaValidation(Message message) |
protected boolean |
AbstractOutDatabindingInterceptor.shouldBuffer(Message message) |
protected boolean |
AbstractOutDatabindingInterceptor.shouldValidate(Message m) |
protected boolean |
AbstractInDatabindingInterceptor.shouldValidate(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 String |
DelegatingAuthenticationInterceptor.getAuthenticationScheme(Message message) |
protected Method |
AbstractAuthorizingInInterceptor.getTargetMethod(Message m) |
protected OperationInfo |
OperationInfoAuthorizingInterceptor.getTargetOperationInfo(Message message) |
void |
OperationInfoAuthorizingInterceptor.handleMessage(Message message) |
void |
JAASLoginInterceptor.handleMessage(Message message) |
void |
DepthRestrictingStreamInterceptor.handleMessage(Message message) |
void |
DelegatingAuthenticationInterceptor.handleMessage(Message message) |
void |
AbstractSecurityContextInInterceptor.handleMessage(Message message) |
void |
AbstractAuthorizingInInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingAuthenticationInterceptor.setSchemeHandlers(Map<String,Interceptor<Message>> handlers) |
Modifier and Type | Method and Description |
---|---|
CallbackHandler |
CallbackHandlerTlsCert.create(Message message) |
CallbackHandler |
CallbackHandlerProviderUsernameToken.create(Message message) |
CallbackHandler |
CallbackHandlerProviderAuthPol.create(Message message) |
CallbackHandler |
CallbackHandlerProvider.create(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
TransformOutInterceptor.handleFault(Message message) |
void |
TransformOutInterceptor.handleMessage(Message message) |
void |
TransformInInterceptor.handleMessage(Message message) |
protected boolean |
TransformOutInterceptor.isHttpVerbSupported(Message message) |
Modifier and Type | Method and Description |
---|---|
boolean |
NoOpFaultListener.faultOccurred(Exception exception,
String description,
Message message) |
boolean |
FaultListener.faultOccurred(Exception exception,
String description,
Message message)
Handle the occurred exception.
|
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 Object |
MessageUtils.getContextualProperty(Message m,
String propPreferred,
String propDefault) |
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.isEmptyPartialResponse(Message message)
Determines if the current message is an empty partial response, which
is a partial response with an empty content.
|
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.
|
static boolean |
PhaseInterceptorChain.setCurrentMessage(PhaseInterceptorChain chain,
Message m) |
void |
PhaseInterceptorChain.unwind(Message message) |
Modifier and Type | Method and Description |
---|---|
<T> void |
PolicyDataEngine.assertMessage(Message message,
T confPol,
PolicyCalculator<T> policyCalculator) |
<T> T |
PolicyDataEngine.getClientEndpointPolicy(Message m,
EndpointInfo ei,
Conduit c,
PolicyCalculator<T> policyCalculator) |
<T> T |
PolicyDataEngine.getPolicy(Message message,
T confPolicy,
PolicyCalculator<T> intersector) |
<T> T |
PolicyDataEngine.getServerEndpointPolicy(Message m,
EndpointInfo ei,
Destination d,
PolicyCalculator<T> policyCalculator) |
boolean |
PolicyCalculator.isAsserted(Message message,
T policy,
T refPolicy) |
Modifier and Type | Method and Description |
---|---|
static XMLStreamReader |
StaxUtils.configureReader(XMLStreamReader xreader,
Message message) |
static boolean |
StaxUtils.isSecureReader(XMLStreamReader reader,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
StaxSchemaValidationOutInterceptor.handleMessage(Message message) |
void |
StaxSchemaValidationInInterceptor.handleMessage(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 |
Assertor.assertMessage(Message message) |
void |
Conduit.close(Message message)
Close the connections associated with the message
|
void |
AbstractConduit.close(Message msg) |
protected Message |
MultipleEndpointObserver.createMessage(Message message)
Give a chance for a Binding to customize their message
|
Conduit |
Destination.getBackChannel(Message inMessage)
Retreive a back-channel Conduit, which must be policy-compatible
with the current Message and associated Destination.
|
Conduit |
AbstractDestination.getBackChannel(Message inMessage)
Retrieve 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 |
MessageObserver.onMessage(Message message)
Called for an incoming message, i.e.
|
void |
ChainInitiationObserver.onMessage(Message m) |
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 |
---|---|
static GZIPOutInterceptor.UseGzip |
GZIPOutInterceptor.gzipPermitted(Message message,
boolean force)
Checks whether we can, cannot or must use gzip compression on this output
message.
|
void |
GZIPOutInterceptor.handleMessage(Message message) |
void |
GZIPInInterceptor.handleMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
protected BeanValidationProvider |
BeanValidationOutInterceptor.getOutProvider(Message message) |
protected BeanValidationProvider |
AbstractValidationInterceptor.getProvider(Message message) |
protected Method |
AbstractValidationInterceptor.getServiceMethod(Message message) |
protected Method |
AbstractBeanValidationInterceptor.getServiceMethod(Message message) |
protected Object |
AbstractValidationInterceptor.getServiceObject(Message message) |
protected Object |
AbstractBeanValidationInterceptor.getServiceObject(Message message) |
void |
AbstractValidationInterceptor.handleMessage(Message message) |
protected void |
BeanValidationOutInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
protected abstract void |
AbstractValidationInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
protected void |
AbstractBeanValidationInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
Modifier and Type | Method and Description |
---|---|
static Message |
ContextUtils.createMessage(Exchange exchange)
Create a Binding specific Message.
|
Modifier and Type | Method and Description |
---|---|
Collection<PhaseInterceptor<? extends Message>> |
MAPAggregator.getAdditionalInterceptors() |
Modifier and Type | Method and Description |
---|---|
static Conduit |
ContextUtils.getConduit(Conduit conduit,
Message message)
Retreive Conduit from Exchange if not already available
|
void |
MAPAggregator.handleFault(Message message) |
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.
|
static void |
ContextUtils.propogateReceivedMAPs(AddressingProperties inMAPs,
Message responseMessage)
Propogate inbound MAPs onto reponse message if applicable
(not applicable for oneways).
|
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 AddressingProperties |
ContextUtils.retrieveMAPs(Message message,
boolean isProviderContext,
boolean isOutbound) |
static AddressingProperties |
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 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.
|
Modifier and Type | Method and Description |
---|---|
static KerberosClient |
KerberosUtils.getClient(Message message,
String type) |
Modifier and Type | Method and Description |
---|---|
void |
STSTokenOutInterceptor.handleMessage(Message message) |
protected void |
STSTokenOutInterceptor.processToken(Message message,
SecurityToken tok) |
Modifier and Type | Method and Description |
---|---|
static TokenStore |
TokenStoreUtils.getTokenStore(Message message) |
abstract TokenStore |
TokenStoreFactory.newTokenStore(String key,
Message message) |
TokenStore |
MemoryTokenStoreFactory.newTokenStore(String key,
Message message) |
TokenStore |
EHCacheTokenStoreFactory.newTokenStore(String key,
Message message) |
Modifier and Type | Field and Description |
---|---|
protected Message |
AbstractSTSClient.message |
Modifier and Type | Field and Description |
---|---|
protected List<Interceptor<? extends Message>> |
AbstractSTSClient.in |
protected List<Interceptor<? extends Message>> |
AbstractSTSClient.inFault |
protected List<Interceptor<? extends Message>> |
AbstractSTSClient.out |
protected List<Interceptor<? extends Message>> |
AbstractSTSClient.outFault |
Modifier and Type | Method and Description |
---|---|
Collection<PhaseInterceptor<? extends Message>> |
AuthPolicyValidatingInterceptor.getAdditionalInterceptors() |
List<Interceptor<? extends Message>> |
AbstractSTSClient.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractSTSClient.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractSTSClient.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractSTSClient.getOutInterceptors() |
Modifier and Type | Method and Description |
---|---|
static STSClient |
STSUtils.getClient(Message message,
String type) |
static STSClient |
STSUtils.getClient(Message message,
String type,
IssuedToken itok) |
static STSClient |
STSUtils.getClientWithIssuer(Message message,
String type,
Element issuer) |
static SecurityToken |
STSTokenRetriever.getToken(Message message,
STSTokenRetriever.TokenRequestParams params) |
static SecurityToken |
STSTokenRetriever.getToken(Message message,
STSTokenRetriever.TokenRequestParams params,
STSTokenCacher tokenCacher) |
void |
AuthPolicyValidatingInterceptor.handleFault(Message arg0) |
void |
AuthPolicyValidatingInterceptor.handleMessage(Message message) |
void |
STSTokenCacher.removeToken(Message message,
SecurityToken securityToken)
Remove a cached STS token
|
void |
DefaultSTSTokenCacher.removeToken(Message message,
SecurityToken securityToken) |
SecurityToken |
STSTokenCacher.retrieveToken(Message message)
Retrieve a cached STS token
|
SecurityToken |
DefaultSTSTokenCacher.retrieveToken(Message message) |
SecurityToken |
STSTokenCacher.retrieveToken(Message message,
Element delegationToken,
String cacheKey)
Retrieve a cached STS token for a given delegation token Element
|
SecurityToken |
DefaultSTSTokenCacher.retrieveToken(Message message,
Element delegationToken,
String cacheKey) |
void |
AbstractSTSClient.setMessage(Message message) |
void |
STSTokenCacher.storeToken(Message message,
Element delegationToken,
String secTokenId,
String cacheKey)
Store a given delegation token in the cache (or update it if it's already there), with a reference to the
security token obtained from the STS.
|
void |
DefaultSTSTokenCacher.storeToken(Message message,
Element delegationToken,
String secTokenId,
String cacheKey) |
void |
STSTokenCacher.storeToken(Message message,
SecurityToken securityToken)
Store a token in the cache
|
void |
DefaultSTSTokenCacher.storeToken(Message message,
SecurityToken securityToken) |
Credential |
STSTokenValidator.validateWithSTS(Credential credential,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSTSClient.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractSTSClient.setInInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractSTSClient.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors) |
void |
AbstractSTSClient.setOutInterceptors(List<Interceptor<? extends Message>> interceptors) |
Modifier and Type | Method and Description |
---|---|
Message |
ClaimsCallback.getCurrentMessage() |
Modifier and Type | Method and Description |
---|---|
void |
ClaimsCallback.setCurrentMessage(Message currentMessage) |
Constructor and Description |
---|
ClaimsCallback(Message currentMessage) |
Modifier and Type | Method and Description |
---|---|
Message |
DelegationCallback.getCurrentMessage() |
Modifier and Type | Method and Description |
---|---|
void |
DelegationCallback.setCurrentMessage(Message currentMessage) |
Constructor and Description |
---|
DelegationCallback(Message currentMessage) |
Modifier and Type | Method and Description |
---|---|
Collection<PhaseInterceptor<? extends Message>> |
PolicyBasedWSS4JOutInterceptor.PolicyBasedWSS4JOutInterceptorInternal.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
AbstractWSS4JStaxInterceptor.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
AbstractWSS4JInterceptor.getAdditionalInterceptors() |
Modifier and Type | Method and Description |
---|---|
static void |
WSS4JTokenConverter.convertToken(Message msg,
Principal p) |
static PasswordEncryptor |
WSS4JUtils.getPasswordEncryptor(Message message) |
static long |
WSS4JUtils.getSecurityTokenLifetime(Message message)
Get the security token lifetime value (in milliseconds).
|
static Crypto |
WSS4JUtils.loadCryptoFromPropertiesFile(Message message,
String propFilename,
ClassLoader classLoader,
PasswordEncryptor passwordEncryptor) |
static String |
WSS4JUtils.parseAndStoreStreamingSecurityToken(org.apache.xml.security.stax.securityToken.SecurityToken securityToken,
Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
PolicyValidatorParameters.getMessage() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractBindingPolicyValidator.checkProperties(AbstractSymmetricAsymmetricBinding binding,
org.apache.cxf.ws.policy.AssertionInfo ai,
org.apache.cxf.ws.policy.AssertionInfoMap aim,
WSHandlerResult results,
List<WSSecurityEngineResult> signedResults,
Message message)
Check various properties set in the policy of the binding
|
static Map<QName,SecurityPolicyValidator> |
ValidatorUtils.getSecurityPolicyValidators(Message message) |
protected boolean |
AbstractSupportingTokenPolicyValidator.isTLSInUse(Message message) |
protected boolean |
AbstractSecurityPolicyValidator.isTokenRequired(AbstractToken token,
Message message)
Check to see if a token is required or not.
|
void |
PolicyValidatorParameters.setMessage(Message message) |
protected boolean |
AbstractBindingPolicyValidator.validateTimestamp(boolean includeTimestamp,
boolean transportBinding,
WSHandlerResult results,
List<WSSecurityEngineResult> signedResults,
Message message)
Validate a Timestamp
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.