| 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 |
|---|---|
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 |
ColocOutInterceptor.handleMessage(Message message) |
void |
WebFaultInInterceptor.handleMessage(Message message) |
void |
ColocInInterceptor.handleMessage(Message msg) |
protected void |
ColocOutInterceptor.invokeColocObserver(Message outMsg,
Endpoint inboundEndpoint) |
void |
ColocMessageObserver.onMessage(Message m) |
protected void |
ColocMessageObserver.setExchangeProperties(Exchange exchange,
Message m) |
| Modifier and Type | Class and Description |
|---|---|
class |
CorbaMessage |
| Modifier and Type | Method and Description |
|---|---|
Message |
CorbaBinding.createMessage() |
Message |
CorbaBinding.createMessage(Message m) |
| Modifier and Type | Method and Description |
|---|---|
List<Interceptor<? extends Message>> |
CorbaBinding.getFaultInInterceptors() |
List<Interceptor<? extends Message>> |
CorbaBinding.getFaultOutInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
void |
CorbaServerConduit.close(Message message) |
void |
CorbaConduit.close(Message message) |
Message |
CorbaBinding.createMessage(Message m) |
Conduit |
CorbaDestination.getBackChannel(Message inMessage) |
void |
CorbaServerConduit.prepare(Message message) |
void |
CorbaConduit.prepare(Message message) |
| Constructor and Description |
|---|
CorbaMessage(Message m) |
| Modifier and Type | Method and Description |
|---|---|
void |
CorbaStreamFaultInInterceptor.handleMessage(Message msg) |
void |
CorbaStreamOutInterceptor.handleMessage(Message msg) |
void |
CorbaStreamOutEndingInterceptor.handleMessage(Message msg) |
void |
CorbaStreamFaultOutInterceptor.handleMessage(Message msg) |
void |
CorbaStreamInInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
ContextUtils.isOutbound(Message message)
Determine if message is outbound.
|
static boolean |
ContextUtils.isRequestor(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,
XMLStreamWriter xmlWriter,
boolean output,
BindingOperationInfo boi) |
protected DataWriter<XMLStreamWriter> |
SoapOutInterceptor.getDataWriter(Message message) |
static String |
SoapActionInInterceptor.getSoapAction(Message m) |
protected XMLStreamWriter |
RPCOutInterceptor.getXMLStreamWriter(Message message) |
void |
RPCOutInterceptor.handleMessage(Message message) |
void |
RPCInInterceptor.handleMessage(Message message) |
void |
SoapHeaderInterceptor.handleMessage(Message m) |
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 |
|---|---|
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 |
XMLMessageInInterceptor.handleMessage(Message message) |
void |
XMLMessageOutInterceptor.handleMessage(Message message) |
void |
XMLFaultOutInterceptor.handleMessage(Message message) |
void |
XMLFaultInInterceptor.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 |
|---|---|
Object |
PerRequestResourceProvider.getInstance(Message m) |
Object |
SingletonResourceProvider.getInstance(Message m) |
void |
PerRequestResourceProvider.releaseInstance(Message m,
Object o) |
void |
SingletonResourceProvider.releaseInstance(Message m,
Object o) |
| Modifier and Type | Method and Description |
|---|---|
void |
FailoverTargetSelector.prepare(Message message)
Called prior to the interceptor chain being traversed.
|
protected boolean |
FailoverTargetSelector.replaceEndpointAddressPropertyIfNeeded(Message message,
String endpointAddress,
Conduit cond) |
Conduit |
LoadDistributorTargetSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
FailoverTargetSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
CircuitBreakerTargetSelector.selectConduit(Message message) |
| 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 |
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 |
PreexistingConduitSelector.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 |
NullConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
DeferredConduitSelector.selectConduit(Message message)
Called when a Conduit is actually required.
|
Conduit |
PreexistingConduitSelector.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 |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
LoggingInInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractLoggingInterceptor.createExchangeId(Message message) |
void |
WireTapIn.handleMessage(Message message) |
void |
LoggingInInterceptor.handleMessage(Message message) |
void |
LoggingOutInterceptor.handleMessage(Message message) |
protected static boolean |
AbstractLoggingInterceptor.isLoggingDisabledNow(Message message) |
String |
MaskSensitiveHelper.maskSensitiveElements(Message message,
String originalLogString) |
protected String |
AbstractLoggingInterceptor.maskSensitiveElements(Message message,
String originalLogString) |
protected String |
AbstractLoggingInterceptor.transform(Message message,
String originalLogString) |
| Constructor and Description |
|---|
LoggingCallback(LogEventSender sender,
Message msg,
OutputStream os,
int limit) |
| Modifier and Type | Method and Description |
|---|---|
EventType |
DefaultLogEventMapper.getEventType(Message message)
Gets the event type from message.
|
LogEvent |
DefaultLogEventMapper.map(Message message) |
LogEvent |
DefaultLogEventMapper.map(Message message,
Set<String> sensitiveProtocolHeaders) |
void |
DefaultLogEventMapper.setEpInfo(Message message,
LogEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractXSLTInterceptor.checkContextProperty(Message message) |
void |
XSLTInInterceptor.handleMessage(Message message) |
void |
XSLTOutInterceptor.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 |
|---|---|
protected void |
WSDLGetInterceptor.cleanUpOutInterceptors(Message outMessage) |
Document |
WSDLGetUtils.getDocument(Message message,
String base,
Map<String,String> params,
String ctxUri,
EndpointInfo endpointInfo) |
protected String |
WSDLGetUtils.getPublishedEndpointURL(Message message,
String base,
EndpointInfo endpointInfo)
Retrieve the published endpoint url from the working information set.
|
Map<String,String> |
WSDLGetUtils.getSchemaLocations(Message message,
String base,
String ctxUri,
EndpointInfo endpointInfo) |
Set<String> |
WSDLGetUtils.getWSDLIds(Message message,
String base,
String ctxUri,
EndpointInfo endpointInfo) |
void |
WSDLGetInterceptor.handleMessage(Message message) |
void |
WSDLGetOutInterceptor.handleMessage(Message message) |
protected void |
WSDLGetUtils.updateDoc(Document doc,
String base,
Map<String,javax.wsdl.Definition> mp,
Map<String,javax.wsdl.extensions.schema.SchemaReference> smp,
Message message,
String xsdWsdlPar) |
protected void |
WSDLGetUtils.updateDoc(Document doc,
String base,
Map<String,javax.wsdl.Definition> mp,
Map<String,javax.wsdl.extensions.schema.SchemaReference> smp,
Message message,
String xsd,
String wsdl)
Deprecated.
|
protected void |
WSDLGetUtils.updateWSDLKeyDefinition(Bus bus,
Map<String,javax.wsdl.Definition> mp,
Message message,
Map<String,javax.wsdl.extensions.schema.SchemaReference> smp,
String base,
EndpointInfo endpointInfo)
Create a wsdl Definition object from the endpoint information and register
it in the local data structure for future reference.
|
Document |
WSDLGetUtils.writeWSDLDocument(Message message,
Map<String,javax.wsdl.Definition> mp,
Map<String,javax.wsdl.extensions.schema.SchemaReference> smp,
String wsdl,
String base,
EndpointInfo endpointInfo)
Write the contents of a wsdl Definition object to a file.
|
| Constructor and Description |
|---|
WSDLGetInterceptor(Interceptor<Message> outInterceptor) |
| 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>> |
AbstractBasicInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.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>> |
AbstractBasicInterceptorProvider.getInInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getInInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.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>> |
AbstractBasicInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.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>> |
AbstractBasicInterceptorProvider.getOutInterceptors() |
List<Interceptor<? extends Message>> |
AbstractAttributedInterceptorProvider.getOutInterceptors() |
List<Interceptor<? extends Message>> |
AnnotationInterceptors.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 |
OneWayProcessorInterceptor.handleFault(Message message) |
void |
StaxOutInterceptor.handleFault(Message message) |
void |
AttachmentInInterceptor.handleFault(Message messageParam) |
void |
FIStaxOutInterceptor.handleFault(Message message) |
void |
ServiceInvokerInterceptor.handleMessage(Message message) |
void |
OutgoingChainInterceptor.handleMessage(Message message) |
void |
OneWayProcessorInterceptor.handleMessage(Message message) |
void |
ClientFaultConverter.handleMessage(Message msg) |
void |
MessageSenderInterceptor.handleMessage(Message message) |
void |
MessageSenderInterceptor.MessageSenderEndingInterceptor.handleMessage(Message message) |
void |
StaxOutInterceptor.handleMessage(Message message) |
void |
StaxOutEndingInterceptor.handleMessage(Message message) |
void |
AttachmentOutInterceptor.handleMessage(Message message) |
void |
AttachmentOutInterceptor.AttachmentOutEndingInterceptor.handleMessage(Message message) |
void |
StaxInInterceptor.handleMessage(Message message) |
void |
StaxInEndingInterceptor.handleMessage(Message message) |
void |
FIStaxInInterceptor.handleMessage(Message message) |
void |
AttachmentInInterceptor.handleMessage(Message message) |
void |
FaultOutInterceptor.handleMessage(Message message) |
void |
LoggingInInterceptor.handleMessage(Message message)
Deprecated.
|
void |
FIStaxOutInterceptor.handleMessage(Message message) |
void |
LoggingOutInterceptor.handleMessage(Message message)
Deprecated.
|
protected boolean |
FIStaxInInterceptor.isHttpVerbSupported(Message message) |
protected static boolean |
AbstractLoggingInterceptor.isLoggingDisabledNow(Message message)
Deprecated.
|
protected boolean |
FIStaxInInterceptor.isRequestor(Message message) |
protected void |
LoggingInInterceptor.logging(Logger logger,
Message message)
Deprecated.
|
protected void |
LoggingInInterceptor.logInputStream(Message message,
InputStream is,
LoggingMessage buffer,
String encoding,
String ct)
Deprecated.
|
protected void |
LoggingInInterceptor.logReader(Message message,
Reader reader,
LoggingMessage buffer)
Deprecated.
|
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 |
AbstractInDatabindingInterceptor.setOperationSchemaValidation(Message message) |
protected void |
AbstractOutDatabindingInterceptor.setOperationSchemaValidation(Message message) |
protected boolean |
AbstractOutDatabindingInterceptor.shouldBuffer(Message message) |
protected boolean |
AbstractInDatabindingInterceptor.shouldValidate(Message message) |
protected boolean |
AbstractOutDatabindingInterceptor.shouldValidate(Message m) |
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 OperationInfo |
OperationInfoAuthorizingInterceptor.getTargetOperationInfo(Message message) |
void |
OperationInfoAuthorizingInterceptor.handleMessage(Message message) |
void |
DelegatingAuthenticationInterceptor.handleMessage(Message message) |
void |
AbstractSecurityContextInInterceptor.handleMessage(Message message) |
void |
JAASLoginInterceptor.handleMessage(Message message) |
void |
DepthRestrictingStreamInterceptor.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 |
CallbackHandlerProviderAuthPol.create(Message message) |
CallbackHandler |
CallbackHandlerProviderUsernameToken.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 | Field and Description |
|---|---|
static Interceptor<? extends Message> |
JavascriptGetInterceptor.INSTANCE |
| Modifier and Type | Method and Description |
|---|---|
void |
JavascriptGetInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected ValidationEventHandler |
JAXBDataBase.getValidationEventHandler(Message m,
String property) |
| Modifier and Type | Method and Description |
|---|---|
void |
JAXBAttachmentSchemaValidationHack.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Message |
JAXRSBinding.createMessage() |
Message |
JAXRSBinding.createMessage(Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected AsyncResponseImpl |
JAXRSInvoker.checkFutureResponse(Message inMessage,
Object result) |
Message |
JAXRSBinding.createMessage(Message m) |
protected javax.ws.rs.core.MultivaluedMap<String,String> |
JAXRSInvoker.getTemplateValues(Message msg) |
| Modifier and Type | Method and Description |
|---|---|
Object |
BlueprintResourceFactory.getInstance(Message m) |
void |
BlueprintResourceFactory.releaseInstance(Message m,
Object o) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
ClientProxyImpl.createMessage(Object body,
OperationResourceInfo ori,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
URI currentURI,
Exchange exchange,
Map<String,Object> invocationContext,
boolean isProxy) |
protected Message |
AbstractClient.createMessage(Object body,
String httpMethod,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
URI currentURI,
Exchange exchange,
Map<String,Object> invocationContext,
boolean proxy) |
| Modifier and Type | Method and Description |
|---|---|
List<Interceptor<? extends Message>> |
ClientConfiguration.getInFaultInterceptors() |
List<Interceptor<? extends Message>> |
ClientConfiguration.getInInterceptors() |
List<Interceptor<? extends Message>> |
ClientConfiguration.getOutFaultInterceptors() |
List<Interceptor<? extends Message>> |
ClientConfiguration.getOutInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
protected javax.ws.rs.client.InvocationCallback<Object> |
ClientProxyImpl.checkAsyncCallback(OperationResourceInfo ori,
Map<String,Object> reqContext,
Message outMessage) |
protected void |
AbstractClient.checkClientException(Message outMessage,
Exception ex) |
protected void |
ClientProxyImpl.checkResponse(Method m,
javax.ws.rs.core.Response r,
Message inMessage) |
protected void |
AbstractClient.AbstractClientAsyncResponseInterceptor.closeAsyncResponseIfPossible(javax.ws.rs.core.Response r,
Message outMessage,
JaxrsClientCallback<?> cb) |
protected Exchange |
AbstractClient.createExchange(Message m,
Exchange exchange) |
<T extends Throwable> |
ClientProviderFactory.createResponseExceptionMapper(Message m,
Class<?> paramType) |
protected abstract void |
AbstractClient.AbstractClientAsyncResponseInterceptor.doHandleAsyncResponse(Message message,
javax.ws.rs.core.Response r,
JaxrsClientCallback<?> cb) |
protected Object |
ClientProxyImpl.doInvokeAsync(OperationResourceInfo ori,
Message outMessage,
javax.ws.rs.client.InvocationCallback<Object> asyncCallback) |
protected javax.ws.rs.core.Response |
WebClient.doResponse(Message m,
Class<?> responseClass,
Type outGenericType) |
protected void |
AbstractClient.doRunInterceptorChain(Message m) |
protected void |
ClientProxyImpl.BodyWriter.doWriteBody(Message outMessage,
Object body,
Type bodyType,
Annotation[] customAnns,
OutputStream os) |
protected abstract void |
AbstractClient.AbstractBodyWriter.doWriteBody(Message outMessage,
Object body,
Type bodyType,
Annotation[] customAnns,
OutputStream os) |
protected static ResponseExceptionMapper<?> |
ClientProxyImpl.findExceptionMapper(Message message,
Class<?> exType) |
javax.ws.rs.core.Configuration |
ClientProviderFactory.getConfiguration(Message m) |
static ClientProviderFactory |
ClientProviderFactory.getInstance(Message m) |
protected Map<String,Object> |
AbstractClient.getRequestContext(Message outMessage) |
protected Class<?> |
ClientProxyImpl.getReturnType(Method method,
Message outMessage) |
protected void |
AbstractClient.AbstractClientAsyncResponseInterceptor.handleAsyncFault(Message message) |
void |
AbstractClient.AbstractClientAsyncResponseInterceptor.handleFault(Message message) |
void |
AbstractClient.AbstractBodyWriter.handleMessage(Message outMessage) |
void |
AbstractClient.AbstractClientAsyncResponseInterceptor.handleMessage(Message message) |
protected Object |
ClientProxyImpl.handleResponse(Message outMessage,
Class<?> serviceCls) |
protected javax.ws.rs.core.Response |
WebClient.handleResponse(Message outMessage,
Class<?> responseClass,
Type genericType) |
protected JaxrsClientCallback<?> |
ClientProxyImpl.newJaxrsClientCallback(javax.ws.rs.client.InvocationCallback<Object> asyncCallback,
Message outMessage,
Class<?> responseClass,
Type outGenericType) |
protected void |
AbstractClient.prepareConduitSelector(Message message,
URI currentURI,
boolean proxy) |
protected Object[] |
AbstractClient.preProcessResult(Message message) |
protected <T> T |
AbstractClient.readBody(javax.ws.rs.core.Response r,
Message outMessage,
Class<T> cls,
Type type,
Annotation[] anns) |
protected boolean |
AbstractClient.responseStreamCanBeClosed(Message outMessage,
Class<?> cls) |
protected void |
AbstractClient.setContexts(Message message,
Exchange exchange,
Map<String,Object> context,
boolean proxy) |
protected void |
AbstractClient.setEmptyRequestPropertyIfNeeded(Message outMessage,
Object body) |
protected void |
AbstractClient.setPlainOperationNameProperty(Message outMessage,
String name) |
protected javax.ws.rs.core.Response.ResponseBuilder |
AbstractClient.setResponseBuilder(Message outMessage,
Exchange exchange) |
protected void |
AbstractClient.setSupportOnewayResponseProperty(Message outMessage) |
protected <T> void |
AbstractClient.writeBody(T o,
Message outMessage,
Class<?> cls,
Type type,
Annotation[] anns,
OutputStream os) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientConfiguration.setInFaultInterceptors(List<Interceptor<? extends Message>> interceptors)
Sets the list of in fault interceptors which will deal with the HTTP
faults; the client code may choose to catch
WebApplicationException
exceptions instead. |
void |
ClientConfiguration.setInInterceptors(List<Interceptor<? extends Message>> interceptors)
Sets the list of in interceptors which pre-process
the responses from remote services.
|
void |
ClientConfiguration.setOutFaultInterceptors(List<Interceptor<? extends Message>> interceptors)
Sets the list of out fault interceptors which will deal with the client-side
faults; the client code may choose to catch
ClientException
exceptions instead. |
void |
ClientConfiguration.setOutInterceptors(List<Interceptor<? extends Message>> interceptors)
Sets the list of out interceptors which post-process
the requests to the remote services.
|
| Modifier and Type | Method and Description |
|---|---|
protected javax.ws.rs.core.Response |
ClientResponseFilterInterceptor.getResponse(Message inMessage) |
void |
ClientRequestFilterInterceptor.handleMessage(Message outMessage) |
void |
ClientResponseFilterInterceptor.handleMessage(Message inMessage) |
| Constructor and Description |
|---|
ClientRequestContextImpl(Message m,
boolean responseContext) |
ClientResponseContextImpl(ResponseImpl r,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JAXRSClientBeanValidationOutInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
| Modifier and Type | Method and Description |
|---|---|
int |
ResourceComparator.compare(ClassResourceInfo cri1,
ClassResourceInfo cri2,
Message message)
Compares two resource classes
|
int |
ResourceComparator.compare(OperationResourceInfo oper1,
OperationResourceInfo oper2,
Message message)
Compares two resource methods
|
T |
ContextProvider.createContext(Message message)
Creates the context instance
|
| Constructor and Description |
|---|
MessageContextImpl(Message m) |
ProtocolHeadersImpl(Message m) |
| Modifier and Type | Method and Description |
|---|---|
QueryContext |
QueryContextProvider.createContext(Message message) |
SearchContext |
SearchContextProvider.createContext(Message message) |
| Constructor and Description |
|---|
SearchContextImpl(Message message) |
| Modifier and Type | Field and Description |
|---|---|
protected Message |
AbstractPropertiesImpl.m |
protected Message |
AbstractResponseContextImpl.m |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
CacheControlHeaderProvider.getCurrentMessage() |
Message |
AbstractPropertiesImpl.getMessage() |
Message |
ResponseImpl.getOutMessage() |
| Modifier and Type | Method and Description |
|---|---|
static PropertyHolderFactory.PropertyHolder |
PropertyHolderFactory.getPropertyHolder(Message m) |
protected Level |
WebApplicationExceptionMapper.getStackTraceLogLevel(Message msg,
javax.ws.rs.core.Response r) |
String |
RequestPreprocessor.preprocess(Message m,
javax.ws.rs.core.UriInfo u) |
void |
ResponseImpl.setOutMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
void |
JAXRSOutInterceptor.handleFault(Message message) |
void |
JAXRSOutExceptionMapperInterceptor.handleFault(Message message)
Deprecated.
|
void |
JAXRSDefaultFaultOutInterceptor.handleFault(Message message) |
void |
JAXRSInInterceptor.handleMessage(Message message) |
void |
JAXRSOutInterceptor.handleMessage(Message message) |
void |
JAXRSOutExceptionMapperInterceptor.handleMessage(Message message)
Deprecated.
|
void |
JAXRSDefaultFaultOutInterceptor.handleMessage(Message message) |
protected boolean |
JAXRSDefaultFaultOutInterceptor.mustPropogateException(Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
PerRequestResourceProvider.createInstance(Message m) |
Object |
PerRequestResourceProvider.getInstance(Message m)
Returns the resource instance which will handle the current request
|
Object |
SingletonResourceProvider.getInstance(Message m)
Returns the resource instance which will handle the current request
|
Object |
ResourceProvider.getInstance(Message m)
Returns the resource instance which will handle the current request
|
void |
PerRequestResourceProvider.releaseInstance(Message m,
Object o)
Releases the resource instance if needed
|
void |
SingletonResourceProvider.releaseInstance(Message m,
Object o)
Releases the resource instance if needed
|
void |
ResourceProvider.releaseInstance(Message m,
Object o)
Releases the resource instance if needed
|
| Modifier and Type | Method and Description |
|---|---|
ClassResourceInfo |
ClassResourceInfo.getSubResource(Class<?> typedClass,
Class<?> instanceClass,
Object instance,
boolean resolveContexts,
Message message) |
void |
ClassResourceInfo.injectContexts(Object resourceObject,
OperationResourceInfo ori,
Message inMessage) |
| Constructor and Description |
|---|
ClassResourceInfoComparator(Message m) |
OperationResourceInfoComparator(Message m,
String method) |
OperationResourceInfoComparator(Message m,
String httpMethod,
boolean getMethod,
javax.ws.rs.core.MediaType contentType,
List<javax.ws.rs.core.MediaType> acceptTypes) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
WadlGenerator.doFilter(javax.ws.rs.container.ContainerRequestContext context,
Message m) |
StringBuilder |
WadlGenerator.generateWADL(String baseURI,
List<ClassResourceInfo> cris,
boolean isJson,
Message m,
javax.ws.rs.core.UriInfo ui) |
protected String |
WadlGenerator.getBaseURI(Message m,
javax.ws.rs.core.UriInfo ui) |
javax.ws.rs.core.Response |
WadlGenerator.getExistingResource(Message m,
javax.ws.rs.core.UriInfo ui,
String href) |
javax.ws.rs.core.Response |
WadlGenerator.getExistingWadl(Message m,
javax.ws.rs.core.UriInfo ui,
javax.ws.rs.core.MediaType mt) |
List<ClassResourceInfo> |
WadlGenerator.getResourcesList(Message m,
javax.ws.rs.core.UriInfo ui) |
| Modifier and Type | Method and Description |
|---|---|
static void |
ServerProviderFactory.clearThreadLocalProxies(Message message) |
static void |
ServerProviderFactory.clearThreadLocalProxies(ServerProviderFactory factory,
Message message) |
<T> ContextProvider<T> |
ProviderFactory.createContextProvider(Type contextType,
Message m) |
<T> javax.ws.rs.ext.ContextResolver<T> |
ProviderFactory.createContextResolver(Type contextType,
Message m) |
<T> javax.ws.rs.ext.ContextResolver<T> |
ProviderFactory.createContextResolver(Type contextType,
Message m,
javax.ws.rs.core.MediaType type) |
<T extends Throwable> |
ServerProviderFactory.createExceptionMapper(Class<?> exceptionType,
Message m) |
<T> javax.ws.rs.ext.MessageBodyReader<T> |
ProviderFactory.createMessageBodyReader(Class<T> type,
Type genericType,
Annotation[] annotations,
javax.ws.rs.core.MediaType mediaType,
Message m) |
<T> List<javax.ws.rs.ext.ReaderInterceptor> |
ProviderFactory.createMessageBodyReaderInterceptor(Class<T> bodyType,
Type parameterType,
Annotation[] parameterAnnotations,
javax.ws.rs.core.MediaType mediaType,
Message m,
boolean checkMbrNow,
Set<String> names) |
<T> javax.ws.rs.ext.MessageBodyWriter<T> |
ProviderFactory.createMessageBodyWriter(Class<T> type,
Type genericType,
Annotation[] annotations,
javax.ws.rs.core.MediaType mediaType,
Message m) |
<T> List<javax.ws.rs.ext.WriterInterceptor> |
ProviderFactory.createMessageBodyWriterInterceptor(Class<T> bodyType,
Type parameterType,
Annotation[] parameterAnnotations,
javax.ws.rs.core.MediaType mediaType,
Message m,
Set<String> names) |
<T> javax.ws.rs.ext.ParamConverter<T> |
ProviderFactory.createParameterHandler(Class<T> paramType,
Type genericType,
Annotation[] anns,
Message m) |
javax.ws.rs.core.Configuration |
ServerProviderFactory.getConfiguration(Message m) |
abstract javax.ws.rs.core.Configuration |
ProviderFactory.getConfiguration(Message message) |
static ServerProviderFactory |
ServerProviderFactory.getInstance(Message m) |
static ProviderFactory |
ProviderFactory.getInstance(Message m) |
protected <T> boolean |
ProviderFactory.handleMapper(ProviderInfo<T> em,
Class<?> expectedType,
Message m,
Class<?> providerClass,
boolean injectContext) |
protected <T> boolean |
ProviderFactory.handleMapper(ProviderInfo<T> em,
Class<?> expectedType,
Message m,
Class<?> providerClass,
Class<?> commonBaseClass,
boolean injectContext) |
protected void |
ServerProviderFactory.injectContextValues(ProviderInfo<?> pi,
Message m) |
protected void |
ProviderFactory.injectContextValues(ProviderInfo<?> pi,
Message m) |
static void |
ServerProviderFactory.releaseRequestState(Message message) |
static void |
ServerProviderFactory.releaseRequestState(ServerProviderFactory factory,
Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
DOM4JProvider.getCurrentMessage() |
| Modifier and Type | Method and Description |
|---|---|
protected String |
AbstractJsonpOutInterceptor.getCallbackValue(Message message) |
protected String |
JsonpInInterceptor.getCallbackValue(Message message) |
protected String |
JsonpJaxrsWriterInterceptor.getCallbackValue(Message message) |
void |
JsonpPreStreamInterceptor.handleMessage(Message message) |
void |
JsonpInInterceptor.handleMessage(Message message) |
void |
JsonpPostStreamInterceptor.handleMessage(Message message) |
protected void |
JsonpPreStreamInterceptor.setContentType(Message message) |
protected void |
AbstractJsonpOutInterceptor.writeValue(Message message,
String value) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractReactiveInvoker.isJsonResponse(Message inMessage) |
protected boolean |
AbstractReactiveInvoker.isStreamingSubscriberUsed(org.reactivestreams.Publisher<?> publisher,
javax.ws.rs.container.AsyncResponse asyncResponse,
Message inMessage) |
| Modifier and Type | Method and Description |
|---|---|
protected AsyncResponseImpl |
ReactorInvoker.checkFutureResponse(Message inMessage,
Object result) |
| Modifier and Type | Method and Description |
|---|---|
protected AsyncResponseImpl |
ReactiveIOInvoker.checkFutureResponse(Message inMessage,
Object result) |
protected AsyncResponseImpl |
ReactiveIOInvoker.handleFlowable(Message inMessage,
io.reactivex.rxjava3.core.Flowable<?> f) |
protected AsyncResponseImpl |
ReactiveIOInvoker.handleMaybe(Message inMessage,
io.reactivex.rxjava3.core.Maybe<?> maybe) |
protected AsyncResponseImpl |
ReactiveIOInvoker.handleObservable(Message inMessage,
io.reactivex.rxjava3.core.Observable<?> obs) |
protected AsyncResponseImpl |
ReactiveIOInvoker.handleSingle(Message inMessage,
io.reactivex.rxjava3.core.Single<?> single) |
| Modifier and Type | Method and Description |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
KerberosAuthOutInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
protected javax.ws.rs.core.Response |
JAASAuthenticationFilter.handleAuthenticationException(SecurityException ex,
Message m) |
void |
KerberosAuthOutInterceptor.handleFault(Message message) |
void |
KerberosAuthOutInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Object |
SpringResourceFactory.getInstance(Message m)
Returns the resource instance which will handle the current request
|
protected void |
SpringResourceFactory.initInstance(Message m,
Object instance) |
void |
SpringResourceFactory.releaseInstance(Message m,
Object o)
Releases the resource instance if needed
|
| Modifier and Type | Method and Description |
|---|---|
javax.ws.rs.sse.Sse |
SseContextProvider.createContext(Message message) |
javax.ws.rs.sse.SseEventSink |
SseEventSinkContextProvider.createContext(Message message) |
| Modifier and Type | Method and Description |
|---|---|
void |
SseInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
static Message |
JAXRSUtils.getContextMessage(Message m) |
static Message |
JAXRSUtils.getCurrentMessage() |
| Modifier and Type | Method and Description |
|---|---|
static <T extends Throwable> |
JAXRSUtils.convertFaultToResponse(T ex,
Message currentMessage) |
static <T extends Throwable> |
ExceptionUtils.convertFaultToResponse(T ex,
Message currentMessage) |
static Object |
JAXRSUtils.createBeanParamValue(Message m,
Class<?> clazz,
OperationResourceInfo ori) |
static Object[] |
ResourceUtils.createConstructorArguments(Constructor<?> c,
Message m,
boolean perRequest) |
static Object[] |
ResourceUtils.createConstructorArguments(Constructor<?> c,
Message m,
boolean perRequest,
Map<Class<?>,Object> contextValues) |
static Object[] |
ResourceUtils.createConstructorArguments(Constructor<?> c,
Message m,
boolean perRequest,
Map<Class<?>,Object> contextValues,
Class<?>[] params,
Annotation[][] anns,
Type[] genericTypes) |
static javax.ws.rs.ext.ContextResolver<?> |
JAXRSUtils.createContextResolver(Type genericType,
Message m) |
static <T> T |
JAXRSUtils.createContextValue(Message m,
Type genericType,
Class<T> clazz) |
static <T> T |
InjectionUtils.createFromParameterHandler(String value,
Class<T> pClass,
Type genericType,
Annotation[] anns,
Message message) |
static Object |
JAXRSUtils.createHttpParameterValue(Parameter parameter,
Class<?> parameterClass,
Type genericParam,
Annotation[] paramAnns,
Message message,
javax.ws.rs.core.MultivaluedMap<String,String> values,
OperationResourceInfo ori) |
static Object |
InjectionUtils.createParameterObject(List<String> paramValues,
Class<?> paramType,
Type genericType,
Annotation[] paramAnns,
String defaultValue,
boolean decoded,
ParameterType pathParam,
Message message) |
static Object |
JAXRSUtils.createResourceValue(Message m,
Type genericType,
Class<?> clazz) |
static javax.ws.rs.core.Response |
JAXRSUtils.createResponse(List<ClassResourceInfo> cris,
Message msg,
String responseMessage,
int status,
boolean addAllow) |
static <T> T |
HttpUtils.createServletResourceValue(Message m,
Class<T> clazz) |
static OperationResourceInfo |
JAXRSUtils.findTargetMethod(Map<ClassResourceInfo,javax.ws.rs.core.MultivaluedMap<String,String>> matchedResources,
Message message,
String httpMethod,
javax.ws.rs.core.MultivaluedMap<String,String> matchedValues,
String requestContentType,
List<javax.ws.rs.core.MediaType> acceptContentTypes) |
static OperationResourceInfo |
JAXRSUtils.findTargetMethod(Map<ClassResourceInfo,javax.ws.rs.core.MultivaluedMap<String,String>> matchedResources,
Message message,
String httpMethod,
javax.ws.rs.core.MultivaluedMap<String,String> matchedValues,
String requestContentType,
List<javax.ws.rs.core.MediaType> acceptContentTypes,
boolean throwException,
boolean recordMatchedUri) |
static String |
HttpUtils.getBaseAddress(Message m) |
static Message |
JAXRSUtils.getContextMessage(Message m) |
static String |
HttpUtils.getEndpointAddress(Message m) |
static Level |
JAXRSUtils.getExceptionLogLevel(Message message,
Class<? extends javax.ws.rs.WebApplicationException> exClass) |
static javax.ws.rs.core.MultivaluedMap<String,Object> |
HttpUtils.getModifiableHeaders(Message m) |
static <T> javax.ws.rs.core.MultivaluedMap<String,T> |
HttpUtils.getModifiableStringHeaders(Message m) |
static String |
HttpUtils.getOriginalAddress(Message m) |
static <T> Optional<javax.ws.rs.ext.ParamConverter<T>> |
InjectionUtils.getParamConverter(Class<T> pClass,
Type genericType,
Annotation[] anns,
Message message) |
static String |
HttpUtils.getPathToMatch(Message m,
boolean addSlash) |
static String |
HttpUtils.getProtocolHeader(Message m,
String name,
String defaultValue) |
static String |
HttpUtils.getProtocolHeader(Message m,
String name,
String defaultValue,
boolean setOnMessage) |
static ClassResourceInfo |
JAXRSUtils.getRootResource(Message m) |
static List<ClassResourceInfo> |
JAXRSUtils.getRootResources(Message message) |
static String |
JAXRSUtils.getUriTemplate(Message message,
ClassResourceInfo cri,
OperationResourceInfo ori)
Get path URI template, combining base path, class & method templates
|
static String |
JAXRSUtils.getUriTemplate(Message message,
ClassResourceInfo cri,
OperationResourceInfo ori,
OperationResourceInfo subOri)
Get path URI template, combining base path, class & method & subresource templates
|
static Object |
InjectionUtils.handleBean(Class<?> paramType,
Annotation[] paramAnns,
javax.ws.rs.core.MultivaluedMap<String,String> values,
ParameterType pType,
Message message,
boolean decoded) |
static <T> T |
InjectionUtils.handleParameter(String value,
boolean decoded,
Class<T> pClass,
Type genericType,
Annotation[] paramAnns,
ParameterType pType,
Message message) |
static void |
InjectionUtils.injectConstructorProxies(Object o,
AbstractResourceInfo cri,
Message m) |
static void |
InjectionUtils.injectContextFields(Object o,
AbstractResourceInfo cri,
Message m) |
static void |
InjectionUtils.injectContextMethods(Object requestObject,
AbstractResourceInfo cri,
Message message) |
static void |
InjectionUtils.injectContexts(Object requestObject,
AbstractResourceInfo resource,
Message message) |
static void |
JAXRSUtils.injectParameters(OperationResourceInfo ori,
BeanResourceInfo bri,
Object requestObject,
Message message) |
static void |
JAXRSUtils.injectParameters(OperationResourceInfo ori,
Object requestObject,
Message message) |
static void |
InjectionUtils.injectThroughMethod(Object requestObject,
Method method,
Object parameterValue,
Message inMessage) |
static boolean |
FormUtils.isFormPostRequest(Message m) |
static boolean |
HttpUtils.isHttpRequest(Message message) |
static void |
FormUtils.populateMapFromMultipart(javax.ws.rs.core.MultivaluedMap<String,String> params,
MultipartBody body,
Message m,
boolean decode) |
static void |
FormUtils.populateMapFromString(javax.ws.rs.core.MultivaluedMap<String,String> params,
Message m,
String postBody,
String enc,
boolean decode) |
static void |
FormUtils.populateMapFromString(javax.ws.rs.core.MultivaluedMap<String,String> params,
Message m,
String postBody,
String enc,
boolean decode,
javax.servlet.http.HttpServletRequest request) |
static void |
FormUtils.populateMapFromStringOrHttpRequest(javax.ws.rs.core.MultivaluedMap<String,String> params,
Message m,
String postBody,
String enc,
boolean decode) |
static List<Object> |
JAXRSUtils.processParameters(OperationResourceInfo ori,
javax.ws.rs.core.MultivaluedMap<String,String> values,
Message message) |
static boolean |
ExceptionUtils.propogateException(Message m) |
static void |
JAXRSUtils.pushOntoStack(OperationResourceInfo ori,
javax.ws.rs.core.MultivaluedMap<String,String> params,
Message msg) |
static javax.ws.rs.core.Form |
FormUtils.readForm(FormEncodingProvider<javax.ws.rs.core.Form> provider,
Message message) |
static Object |
JAXRSUtils.readFromMessageBodyReader(List<javax.ws.rs.ext.ReaderInterceptor> readers,
Class<?> targetTypeClass,
Type parameterType,
Annotation[] parameterAnnotations,
InputStream is,
javax.ws.rs.core.MediaType mediaType,
Message m) |
static void |
HttpUtils.resetRequestURI(Message m,
String requestURI) |
static void |
FormUtils.restoreForm(FormEncodingProvider<javax.ws.rs.core.Form> provider,
javax.ws.rs.core.Form form,
Message message) |
static boolean |
JAXRSUtils.runContainerRequestFilters(ServerProviderFactory pf,
Message m,
boolean preMatch,
Set<String> names) |
static void |
JAXRSUtils.runContainerResponseFilters(ServerProviderFactory pf,
ResponseImpl r,
Message m,
OperationResourceInfo ori,
Method invoked) |
static Map<ClassResourceInfo,javax.ws.rs.core.MultivaluedMap<String,String>> |
JAXRSUtils.selectResourceClass(List<ClassResourceInfo> resources,
String path,
Message message) |
static void |
JAXRSUtils.setMessageContentType(Message message,
javax.ws.rs.core.Response response) |
static URI |
HttpUtils.toAbsoluteUri(String relativePath,
Message message) |
static URI |
HttpUtils.toAbsoluteUri(URI u,
Message message) |
static void |
HttpUtils.updatePath(Message m,
String path) |
static void |
JAXRSUtils.writeMessageBody(List<javax.ws.rs.ext.WriterInterceptor> writers,
Object entity,
Class<?> type,
Type genericType,
Annotation[] annotations,
javax.ws.rs.core.MediaType mediaType,
javax.ws.rs.core.MultivaluedMap<String,Object> httpHeaders,
Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected BeanValidationProvider |
JAXRSBeanValidationInvoker.getProvider(Message message) |
static Object |
ValidationUtils.getResourceInstance(Message message) |
protected Object |
JAXRSBeanValidationInInterceptor.getServiceObject(Message message) |
protected Object |
JAXRSBeanValidationOutInterceptor.getServiceObject(Message message) |
protected void |
JAXRSBeanValidationInInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
| 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,
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 |
LogicalHandlerFaultOutInterceptor.handleMessage(Message message) |
void |
LogicalHandlerFaultInInterceptor.handleMessage(Message message) |
void |
LogicalHandlerOutInterceptor.handleMessage(Message message) |
void |
LogicalHandlerInInterceptor.handleMessage(Message message) |
| Constructor and Description |
|---|
LogicalMessageContextImpl(Message wrapped) |
| Constructor and Description |
|---|
SOAPMessageContextImpl(Message m) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageModeInInterceptor.handleMessage(Message message) |
void |
MessageModeOutInterceptor.handleMessage(Message message) |
void |
WebFaultOutInterceptor.handleMessage(Message message) |
void |
HolderOutInterceptor.handleMessage(Message message) |
void |
HolderInInterceptor.handleMessage(Message message) |
void |
WrapperClassOutInterceptor.handleMessage(Message message) |
void |
WrapperClassInInterceptor.handleMessage(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 | Method and Description |
|---|---|
void |
ResponseTimeMessageInInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageInvokerInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageOutInterceptor.handleFault(Message message) |
void |
ResponseTimeMessageOutInterceptor.EndingInterceptor.handleFault(Message message) |
void |
PersistInInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageInInterceptor.handleMessage(Message message) |
void |
PersistOutInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageInvokerInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageOutInterceptor.handleMessage(Message message) |
void |
ResponseTimeMessageOutInterceptor.EndingInterceptor.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) |
static boolean |
MessageUtils.getContextualBoolean(Message m,
String key,
boolean defaultValue) |
static int |
MessageUtils.getContextualInteger(Message m,
String key,
int 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 int |
MessageUtils.getReponseCodeFromMessage(Message message)
Gets the response code from the message and tries to deduct one if it
is not set yet.
|
static Optional<Method> |
MessageUtils.getTargetMethod(Message m) |
static boolean |
MessageUtils.hasNoResponseContent(Message message)
Determines if the current message has no response content.
|
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.isOneWay(Message message)
Checks if the message is oneway or not
|
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 | Method and Description |
|---|---|
protected void |
AbstractMetricsInterceptor.addOperationMetrics(ExchangeMetrics ctx,
Message m,
BindingOperationInfo boi) |
protected ExchangeMetrics |
AbstractMetricsInterceptor.getExchangeMetrics(Message m,
boolean create) |
void |
MetricsMessageInInterceptor.handleFault(Message message) |
void |
MetricsMessageClientOutInterceptor.handleFault(Message message) |
void |
CountingOutInterceptor.handleMessage(Message message) |
void |
MetricsMessageInPreInvokeInterceptor.handleMessage(Message message) |
void |
MetricsMessageInPostInvokeInterceptor.handleMessage(Message message) |
void |
MetricsMessageOutInterceptor.handleMessage(Message message) |
void |
MetricsMessageInInterceptor.handleMessage(Message message) |
void |
MetricsMessageClientOutInterceptor.handleMessage(Message message) |
void |
MetricsMessageInOneWayInterceptor.handleMessage(Message message) |
void |
AbstractMetricsInterceptor.stop(Message m) |
| Modifier and Type | Method and Description |
|---|---|
io.micrometer.core.instrument.Tag |
StandardTags.method(Message request) |
io.micrometer.core.instrument.Tag |
StandardTags.outcome(Message response) |
io.micrometer.core.instrument.Tag |
StandardTags.status(Message response) |
io.micrometer.core.instrument.Tag |
StandardTags.uri(Message request) |
| Modifier and Type | Method and Description |
|---|---|
io.micrometer.core.instrument.Tag |
JaxrsTags.method(Message request) |
io.micrometer.core.instrument.Tag |
JaxrsTags.operation(Message request) |
| Modifier and Type | Method and Description |
|---|---|
io.micrometer.core.instrument.Tag |
JaxwsTags.operation(Message request) |
| Modifier and Type | Method and Description |
|---|---|
List<org.eclipse.microprofile.rest.client.ext.ResponseExceptionMapper<?>> |
MicroProfileClientProviderFactory.createResponseExceptionMapper(Message m,
Class<?> paramType) |
javax.ws.rs.core.Configuration |
MicroProfileClientProviderFactory.getConfiguration(Message m) |
static MicroProfileClientProviderFactory |
MicroProfileClientProviderFactory.getInstance(Message m) |
| Constructor and Description |
|---|
MPRestClientCallback(javax.ws.rs.client.InvocationCallback<T> handler,
Message outMessage,
Class<?> responseClass,
Type outGenericType) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
MicroProfileClientProxyImpl.createMessage(Object body,
OperationResourceInfo ori,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
URI currentURI,
Exchange exchange,
Map<String,Object> invocationContext,
boolean proxy) |
| Modifier and Type | Method and Description |
|---|---|
protected javax.ws.rs.client.InvocationCallback<Object> |
MicroProfileClientProxyImpl.checkAsyncCallback(OperationResourceInfo ori,
Map<String,Object> reqContext,
Message outMessage) |
protected boolean |
MicroProfileClientProxyImpl.checkAsyncReturnType(OperationResourceInfo ori,
Map<String,Object> reqContext,
Message outMessage) |
protected void |
MicroProfileClientProxyImpl.checkResponse(Method m,
javax.ws.rs.core.Response r,
Message inMessage) |
protected Object |
MicroProfileClientProxyImpl.doInvokeAsync(OperationResourceInfo ori,
Message outMessage,
javax.ws.rs.client.InvocationCallback<Object> asyncCallback) |
protected void |
MicroProfileClientProxyImpl.doRunInterceptorChain(Message message) |
protected Class<?> |
MicroProfileClientProxyImpl.getReturnType(Method method,
Message outMessage) |
void |
MPAsyncInvocationInterceptorRemoveContextImpl.handleMessage(Message message)
Intercepts a message.
|
void |
MPAsyncInvocationInterceptorPostAsyncImpl.handleMessage(Message message)
Intercepts a message.
|
void |
MPAsyncInvocationInterceptorImpl.handleMessage(Message message)
Intercepts a message.
|
protected JaxrsClientCallback<?> |
MicroProfileClientProxyImpl.newJaxrsClientCallback(javax.ws.rs.client.InvocationCallback<Object> asyncCallback,
Message outMessage,
Class<?> responseClass,
Type outGenericType) |
| 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 CallbackHandler |
RSSecurityUtils.getCallbackHandler(Message message,
Class<?> callingClass) |
static CallbackHandler |
RSSecurityUtils.getCallbackHandler(Message message,
Class<?> callingClass,
String callbackProperty) |
static org.apache.wss4j.common.crypto.Crypto |
RSSecurityUtils.getCrypto(Message message,
String cryptoKey,
String propKey) |
org.apache.wss4j.common.crypto.Crypto |
CryptoLoader.getCrypto(Message message,
String cryptoKey,
String propKey) |
Map<Object,org.apache.wss4j.common.crypto.Crypto> |
CryptoLoader.getCryptoCache(Message message) |
static String |
RSSecurityUtils.getSignaturePassword(Message message,
String userName,
Class<?> callingClass) |
static String |
RSSecurityUtils.getUserName(Message message,
org.apache.wss4j.common.crypto.Crypto crypto,
String userNameKey) |
static boolean |
RSSecurityUtils.isSignedAndEncryptedTwoWay(Message m) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageVerifier.verifyMessage(Map<String,List<String>> messageHeaders,
String method,
String uri,
Message m,
byte[] messageBody) |
| Modifier and Type | Method and Description |
|---|---|
static PrivateKey |
KeyManagementUtils.loadPrivateKey(Message m,
Properties props) |
static PublicKey |
KeyManagementUtils.loadPublicKey(Message m,
Properties props) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
JoseUtils.checkBooleanProperty(JoseHeaders headers,
Properties props,
Message m,
String propertyName) |
static X509Certificate |
KeyManagementUtils.getCertificateFromThumbprint(String thumbprint,
String digestAlgorithm,
Message m,
Properties props) |
static String |
KeyManagementUtils.getKeyAlgorithm(Message m,
Properties props,
String propName,
String defaultAlg) |
static String |
KeyManagementUtils.getKeyId(Message m,
Properties props,
String preferredPropertyName,
KeyOperation keyOper) |
static List<String> |
KeyManagementUtils.loadAndEncodeX509CertificateOrChain(Message m,
Properties props) |
static String |
KeyManagementUtils.loadDigestAndEncodeX509Certificate(Message m,
Properties props,
String digestAlgo) |
static PrivateKeyPasswordProvider |
KeyManagementUtils.loadPasswordProvider(Message m,
Properties props,
KeyOperation keyOper) |
static KeyStore |
KeyManagementUtils.loadPersistKeyStore(Message m,
Properties props) |
static PrivateKey |
KeyManagementUtils.loadPrivateKey(Message m,
Properties props,
KeyOperation keyOper) |
static PrivateKey |
KeyManagementUtils.loadPrivateKey(Message m,
Properties props,
X509Certificate inCert,
KeyOperation keyOper) |
static PrivateKey |
KeyManagementUtils.loadPrivateKey(Message m,
String keyStoreLocProp,
KeyOperation keyOper) |
static PrivateKey |
KeyManagementUtils.loadPrivateKey(Message m,
String keyStoreLocPropPreferred,
String keyStoreLocPropDefault,
KeyOperation keyOper) |
static PublicKey |
KeyManagementUtils.loadPublicKey(Message m,
Properties props) |
static PublicKey |
KeyManagementUtils.loadPublicKey(Message m,
String keyStoreLocProp) |
static PublicKey |
KeyManagementUtils.loadPublicKey(Message m,
String keyStoreLocPropPreferred,
String keyStoreLocPropDefault) |
static Properties |
KeyManagementUtils.loadStoreProperties(Message m,
boolean required,
String storeProp1,
String storeProp2) |
static X509Certificate[] |
KeyManagementUtils.loadX509CertificateOrChain(Message m,
Properties props) |
static void |
KeyManagementUtils.setSha1DigestHeader(JoseHeaders headers,
Message m,
Properties props) |
static void |
KeyManagementUtils.setSha256DigestHeader(JoseHeaders headers,
Message m,
Properties props) |
| Constructor and Description |
|---|
JwsMultipartSignatureInFilter(Message message,
JwsSignatureVerifier verifier,
boolean bufferPayload,
boolean useJwsJsonSignatureFormat) |
| Modifier and Type | Method and Description |
|---|---|
static JsonWebKey |
JwkUtils.loadJsonWebKey(Message m,
Properties props,
KeyOperation keyOper) |
static JsonWebKey |
JwkUtils.loadJsonWebKey(Message m,
Properties props,
KeyOperation keyOper,
String inHeaderKid) |
static List<JsonWebKey> |
JwkUtils.loadJsonWebKeys(Message m,
Properties props,
KeyOperation keyOper) |
static List<JsonWebKey> |
JwkUtils.loadJsonWebKeys(Message m,
Properties props,
KeyOperation keyOper,
PrivateKeyPasswordProvider cb) |
static JsonWebKeys |
JwkUtils.loadJwkSet(Message m,
Properties props,
PrivateKeyPasswordProvider cb) |
static JsonWebKeys |
JwkUtils.loadPublicJwkSet(Message m,
Properties props) |
| Modifier and Type | Method and Description |
|---|---|
static SignatureAlgorithm |
JwsUtils.getSignatureAlgorithm(Message m,
Properties props,
SignatureAlgorithm defaultAlgo) |
static SignatureAlgorithm |
JwsUtils.getSignatureAlgorithm(Message m,
Properties props,
SignatureAlgorithm algo,
SignatureAlgorithm defaultAlgo) |
static Properties |
JwsUtils.loadJwsProperties(Message m,
String propLoc) |
static JsonWebKeys |
JwsUtils.loadPublicVerificationKeys(Message m,
Properties props)
Deprecated.
|
static JsonWebKeys |
JwsUtils.loadPublicVerificationKeys(Message m,
Properties props,
boolean stripPrivateParameters) |
static JwsSignatureProvider |
JwsUtils.loadSignatureProvider(Message m,
Properties props,
JwsHeaders headers) |
static JwsSignatureVerifier |
JwsUtils.loadSignatureVerifier(Message m,
Properties props,
JwsHeaders inHeaders) |
| Modifier and Type | Method and Description |
|---|---|
static void |
JwtUtils.validateJwtAudienceRestriction(JwtClaims claims,
Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected Element |
Saml2BearerAuthHandler.readToken(Message message,
String assertion) |
protected void |
Saml2BearerAuthHandler.validateToken(Message message,
Element element,
String clientId) |
| Modifier and Type | Method and Description |
|---|---|
ClientTokenContext |
ClientTokenContextProvider.createContext(Message m) |
String |
CodeAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
String |
BearerAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
| Modifier and Type | Method and Description |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
OAuthRequestInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
OAuthRequestFilter.checkRequestURI(javax.servlet.http.HttpServletRequest request,
List<String> uris,
Message m) |
protected String[] |
OAuthRequestInterceptor.getAuthorizationParts(Message message) |
protected String[] |
OAuthRequestFilter.getAuthorizationParts(Message m) |
protected String |
OAuthRequestFilter.getTokenFromFormData(Message message) |
void |
OAuthRequestInterceptor.handleFault(Message message) |
void |
OAuthRequestInterceptor.handleMessage(Message message) |
protected boolean |
OAuthRequestFilter.isCorsRequest(Message m) |
protected void |
OAuthRequestFilter.validateRequest(Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected UserSubject |
Saml2BearerGrantHandler.getGrantSubject(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
protected void |
Saml2BearerGrantHandler.setSecurityContext(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
protected void |
Saml2BearerGrantHandler.validateToken(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertion) |
| Modifier and Type | Method and Description |
|---|---|
OAuthContext |
OAuthContextProvider.createContext(Message message) |
| Modifier and Type | Method and Description |
|---|---|
void |
SamlOAuthValidator.validate(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
| Modifier and Type | Method and Description |
|---|---|
IdTokenContext |
OidcIdTokenProvider.createContext(Message m) |
UserInfoContext |
OidcUserInfoProvider.createContext(Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractSamlInHandler.checkHolderOfKey(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertionWrapper,
Certificate[] tlsCerts) |
protected boolean |
AbstractSamlInHandler.checkSenderVouches(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertionWrapper,
Certificate[] tlsCerts)
Check the sender-vouches requirements against the received assertion.
|
protected void |
AbstractSamlInHandler.checkSubjectConfirmationData(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertion) |
protected void |
AbstractSamlInHandler.configureAudienceRestriction(Message msg,
org.apache.wss4j.dom.handler.RequestData reqData) |
static org.apache.wss4j.common.saml.SamlAssertionWrapper |
SAMLUtils.createAssertion(Message message) |
protected org.apache.wss4j.common.saml.SamlAssertionWrapper |
AbstractSamlOutInterceptor.createAssertion(Message message) |
static org.apache.wss4j.common.saml.SamlAssertionWrapper |
SAMLUtils.createAssertion(Message message,
CallbackHandler handler) |
protected javax.ws.rs.core.Form |
SamlFormOutInterceptor.getRequestForm(Message message) |
static Subject |
SAMLUtils.getSubject(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertionW) |
void |
SamlFormOutInterceptor.handleMessage(Message message) |
void |
SamlHeaderOutInterceptor.handleMessage(Message message) |
protected void |
AbstractSamlBase64InHandler.handleToken(Message message,
String assertion) |
protected Document |
SamlEnvelopedOutInterceptor.processDocument(Message message,
Document doc) |
protected Element |
AbstractSamlInHandler.readToken(Message message,
InputStream tokenStream) |
protected void |
AbstractSamlInHandler.setSecurityContext(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
protected void |
AbstractSamlInHandler.validateToken(Message message,
Element tokenElement) |
protected void |
AbstractSamlInHandler.validateToken(Message message,
InputStream tokenStream) |
protected void |
AbstractSamlInHandler.validateToken(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertion) |
| Modifier and Type | Method and Description |
|---|---|
protected SecurityContext |
SecurityContextProviderImpl.doGetSecurityContext(Message message,
Subject subject,
ClaimCollection claims) |
SecurityContext |
SecurityContextProvider.getSecurityContext(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
SecurityContext |
SecurityContextProviderImpl.getSecurityContext(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper) |
protected Subject |
SecurityContextProviderImpl.getSubject(Message message,
org.apache.wss4j.common.saml.SamlAssertionWrapper wrapper,
ClaimCollection claims) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractServiceProviderFilter.checkSecurityContext(Message m) |
org.opensaml.saml.saml2.core.AuthnRequest |
AuthnRequestBuilder.createAuthnRequest(Message message,
String issuerId,
String assertionConsumerServiceAddress)
Create a SAML 2.0 Protocol AuthnRequest
|
org.opensaml.saml.saml2.core.AuthnRequest |
DefaultAuthnRequestBuilder.createAuthnRequest(Message message,
String issuerId,
String assertionConsumerServiceAddress)
Create a SAML 2.0 Protocol AuthnRequest
|
protected SamlRequestInfo |
AbstractServiceProviderFilter.createSamlRequestInfo(Message m) |
protected String |
AbstractSSOSpHandler.getIssuerId(Message m) |
protected ResponseState |
AbstractServiceProviderFilter.getValidResponseState(javax.ws.rs.core.Cookie securityContextCookie,
Message m) |
protected void |
AbstractServiceProviderFilter.setSecurityContext(Message m,
org.apache.wss4j.common.saml.SamlAssertionWrapper assertionWrapper) |
| Modifier and Type | Method and Description |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
XmlSigInInterceptor.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
XmlEncInInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractXmlSigInHandler.checkSignature(Message message) |
protected org.apache.xml.security.stax.securityEvent.SecurityEventListener |
XmlSecInInterceptor.configureSecurityEventListener(org.apache.wss4j.common.crypto.Crypto sigCrypto,
Message msg,
org.apache.xml.security.stax.ext.XMLSecurityProperties securityProperties) |
void |
AbstractXmlEncInHandler.decryptContent(Message message) |
protected byte[] |
AbstractXmlEncInHandler.decryptSymmetricKey(String base64EncodedKey,
X509Certificate cert,
org.apache.wss4j.common.crypto.Crypto crypto,
String keyEncAlgo,
Message message) |
protected byte[] |
AbstractXmlEncInHandler.decryptSymmetricKey(String base64EncodedKey,
X509Certificate cert,
org.apache.wss4j.common.crypto.Crypto crypto,
String keyEncAlgo,
String digestAlgo,
Message message) |
protected Document |
XmlEncOutInterceptor.encryptDocument(Message message,
Document payloadDoc) |
protected Document |
AbstractXmlSecInHandler.getDocument(Message message) |
protected byte[] |
AbstractXmlEncInHandler.getSymmetricKeyBytes(Message message,
Element encDataElement) |
protected String |
AbstractXmlSigInHandler.getUserName(org.apache.wss4j.common.crypto.Crypto crypto,
Message message) |
void |
XmlSigInInterceptor.handleFault(Message message) |
void |
XmlEncInInterceptor.handleFault(Message message) |
void |
XmlSigInInterceptor.handleMessage(Message message) |
void |
AbstractXmlSecOutInterceptor.handleMessage(Message message) |
void |
XmlSecInInterceptor.handleMessage(Message message) |
void |
XmlSecOutInterceptor.handleMessage(Message message) |
void |
XmlEncInInterceptor.handleMessage(Message message) |
protected boolean |
AbstractXmlSecInHandler.isServerGet(Message message) |
protected Document |
XmlEncOutInterceptor.processDocument(Message message,
Document payloadDoc) |
protected Document |
XmlSigOutInterceptor.processDocument(Message message,
Document doc) |
protected abstract Document |
AbstractXmlSecOutInterceptor.processDocument(Message message,
Document doc) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClaimsAuthorizingInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected SecurityContext |
WSS4JBasicAuthValidator.createSecurityContext(Message msg,
org.apache.wss4j.dom.validate.Credential credential) |
protected void |
WSS4JBasicAuthValidator.validate(Message message) |
| Modifier and Type | Method and Description |
|---|---|
static List<String> |
SAMLUtils.getAudienceRestrictions(Message msg,
boolean enableByDefault) |
| Constructor and Description |
|---|
CXFMessageParser(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractXACMLAuthorizingInterceptor.authorize(Principal principal,
List<String> roles,
Message message)
Perform a (remote) authorization decision and return a boolean depending on the result
|
org.opensaml.xacml.ctx.RequestType |
DefaultXACMLRequestBuilder.createRequest(Principal principal,
List<String> roles,
Message message)
Create an XACML Request given a Principal, list of roles and Message.
|
org.opensaml.xacml.ctx.RequestType |
XACMLRequestBuilder.createRequest(Principal principal,
List<String> roles,
Message message)
Create an XACML Request given a Principal, list of roles and Message.
|
void |
AbstractXACMLAuthorizingInterceptor.handleMessage(Message message) |
protected void |
AbstractXACMLAuthorizingInterceptor.handleObligations(org.opensaml.xacml.ctx.RequestType request,
Principal principal,
Message message,
org.opensaml.xacml.ctx.ResultType result)
Handle any Obligations returned by the PDP
|
protected org.opensaml.xacml.ctx.ResponseType |
XACMLAuthorizingInterceptor.performRequest(org.opensaml.xacml.ctx.RequestType request,
Message message) |
protected abstract org.opensaml.xacml.ctx.ResponseType |
AbstractXACMLAuthorizingInterceptor.performRequest(org.opensaml.xacml.ctx.RequestType request,
Message message) |
| Modifier and Type | Method and Description |
|---|---|
static URL |
SecurityUtils.getConfigFileURL(Message message,
String configFileKey,
String configFileDefault) |
static boolean |
SecurityUtils.getSecurityPropertyBoolean(String property,
Message message,
boolean defaultValue)
Get the security property boolean for the given property.
|
static Object |
SecurityUtils.getSecurityPropertyValue(String property,
Message message)
Get the security property value for the given property.
|
static URL |
SecurityUtils.loadResource(Message message,
Object o) |
| 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 | Method and Description |
|---|---|
ThrottleResponse |
ThrottlingManager.getThrottleResponse(String phase,
Message m)
Use information in the message to determine what throttling measures should be taken
|
ThrottleResponse |
SimpleThrottlingManager.getThrottleResponse(String phase,
Message m) |
void |
ThrottlingResponseInterceptor.handleMessage(Message message) |
void |
ThrottlingInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected static URI |
AbstractTracingProvider.getUri(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
AbstractBraveInterceptor.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
AbstractBraveClientInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractBraveInterceptor.handleFault(Message message) |
void |
AbstractBraveClientInterceptor.handleFault(Message message) |
void |
BraveClientStartInterceptor.handleFault(Message message) |
void |
BraveStartInterceptor.handleMessage(Message message) |
void |
BraveStopInterceptor.handleMessage(Message message) |
void |
BraveClientStartInterceptor.handleMessage(Message message) |
void |
BraveClientStopInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
TracerContext |
BraveContextProvider.createContext(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Collection<PhaseInterceptor<? extends Message>> |
AbstractOpenTracingClientInterceptor.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
AbstractOpenTracingInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
void |
OpenTracingClientStartInterceptor.handleFault(Message message) |
void |
AbstractOpenTracingClientInterceptor.handleFault(Message message) |
void |
AbstractOpenTracingInterceptor.handleFault(Message message) |
void |
OpenTracingClientStopInterceptor.handleMessage(Message message) |
void |
OpenTracingClientStartInterceptor.handleMessage(Message message) |
void |
OpenTracingStartInterceptor.handleMessage(Message message) |
void |
OpenTracingStopInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
TracerContext |
OpenTracingContextProvider.createContext(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 |
ChainInitiationObserver.onMessage(Message m) |
void |
MultipleEndpointObserver.onMessage(Message message) |
void |
MessageObserver.onMessage(Message message)
Called for an incoming message, i.e.
|
void |
Conduit.prepare(Message message)
Prepare the message for sending.
|
protected void |
ChainInitiationObserver.setExchangeProperties(Exchange exchange,
Message m) |
protected void |
MultipleEndpointObserver.setExchangeProperties(Exchange exchange,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
GZIPOutInterceptor.UseGzip |
GZIPOutInterceptor.gzipPermitted(Message message)
Checks whether we can, cannot or must use gzip compression on this output
message.
|
void |
GZIPInInterceptor.handleMessage(Message message) |
void |
GZIPOutInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
void |
GZIPFeature.remove(List<Interceptor<? extends Message>> outInterceptors) |
| Modifier and Type | Field and Description |
|---|---|
protected Message |
HTTPConduit.WrappedOutputStream.outMessage |
| Modifier and Type | Method and Description |
|---|---|
Message |
ContinuationProviderFactory.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req)
If the request already has a message associated with it, return it
|
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) |
ContinuationProvider |
ContinuationProviderFactory.createContinuationProvider(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
If this factory can support the given req/resp and
provide a ContinuationProvider, it should create one
and return it.
|
protected abstract OutputStream |
HTTPConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected OutputStream |
URLConnectionHTTPConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected static int |
HTTPConduit.determineConnectionTimeout(Message message,
HTTPClientPolicy csPolicy) |
protected static int |
HTTPConduit.determineReceiveTimeout(Message message,
HTTPClientPolicy csPolicy) |
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) |
org.apache.cxf.configuration.security.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.
|
void |
HttpAuthenticationFaultHandler.handleFault(Message message) |
void |
HttpAuthenticationFaultHandler.handleMessage(Message message) |
protected void |
AbstractHTTPDestination.invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m) |
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 |
HTTPConduit.WrappedOutputStream.propagateConduit(Exchange exchange,
Message in) |
protected void |
HTTPConduit.setHeadersByAuthorizationPolicy(Message message,
URI currentURI)
This call places HTTP Header strings into the headers that are relevant
to the Authorization policies that are set on this conduit by
configuration.
|
protected abstract void |
HTTPConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
protected void |
URLConnectionHTTPConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
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 abstract void |
HTTPConduit.WrappedOutputStream.updateResponseHeaders(Message inMessage) |
void |
Cookies.writeToMessageHeaders(Message message) |
| Constructor and Description |
|---|
Headers(Message message) |
Servlet3ContinuationProvider(javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message inMessage) |
WrappedOutputStream(Message outMessage,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI url) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
JettyHTTPDestination.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
JettyHTTPDestination.flushHeaders(Message outMessage,
boolean getStream) |
protected void |
JettyHTTPDestination.invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m) |
protected void |
JettyHTTPDestination.setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
JettyContinuationWrapper.getMessage() |
Message |
JettyContinuationProviderFactory.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req) |
| Modifier and Type | Method and Description |
|---|---|
ContinuationProvider |
JettyContinuationProviderFactory.createContinuationProvider(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
| Constructor and Description |
|---|
JettyContinuationProvider(javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m) |
JettyContinuationWrapper(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse resp,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
UndertowHTTPDestination.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
UndertowHTTPDestination.invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m) |
protected void |
UndertowHTTPDestination.setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
AsyncHTTPConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected void |
AsyncHTTPConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
protected void |
AsyncHTTPConduit.AsyncWrappedOutputStream.updateResponseHeaders(Message inMessage) |
| Constructor and Description |
|---|
AsyncWrappedOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI uri) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
AsyncHTTPConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected void |
AsyncHTTPConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
protected void |
AsyncHTTPConduit.AsyncWrappedOutputStream.updateResponseHeaders(Message inMessage) |
| Constructor and Description |
|---|
AsyncWrappedOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI uri) |
| Modifier and Type | Method and Description |
|---|---|
String |
AbstractSpnegoAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message) |
String |
DefaultBasicAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
String |
CustomAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
String |
HttpAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI uri,
Message message,
String fullHeader)
The HTTPConduit makes a call to this method to obtain
an Authentication token for http authentication.
|
String |
DigestAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
String |
SpnegoAuthSupplier.getAuthorization(org.apache.cxf.configuration.security.AuthorizationPolicy authPolicy,
URI currentURI,
Message message,
String fullHeader) |
protected boolean |
AbstractSpnegoAuthSupplier.isCredDelegationRequired(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
NettyHttpConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected static int |
NettyHttpConduit.determineMaxResponseContentLength(Message message) |
protected void |
NettyHttpConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
protected void |
NettyHttpConduit.NettyWrappedOutputStream.updateResponseHeaders(Message inMessage) |
| Constructor and Description |
|---|
NettyWrappedOutputStream(Message message,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI url) |
| Modifier and Type | Method and Description |
|---|---|
protected Message |
NettyHttpDestination.retrieveFromContinuation(javax.servlet.http.HttpServletRequest req) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
NettyHttpDestination.invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m) |
protected void |
NettyHttpDestination.setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClientPolicyCalculator.isAsserted(Message message,
HTTPClientPolicy policy,
HTTPClientPolicy refPolicy) |
boolean |
ServerPolicyCalculator.isAsserted(Message message,
HTTPServerPolicy policy,
HTTPServerPolicy refPolicy) |
| Modifier and Type | Method and Description |
|---|---|
void |
CertConstraintsInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
void |
JMSConduit.close(Message msg) |
protected Conduit |
JMSDestination.getInbuiltBackChannel(Message inMessage) |
protected static boolean |
JMSConduit.isSetReplyTo(Message message) |
void |
JMSConduit.prepare(Message message)
Prepare the message to be sent.
|
| Constructor and Description |
|---|
JMSContinuation(Bus b,
Message m,
MessageObserver observer,
Counter suspendendContinuations) |
JMSContinuationProvider(Bus b,
Message m,
MessageObserver observer,
Counter suspendendContinuations) |
| 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 |
|---|---|
void |
UDPConduit.close(Message msg) |
protected Conduit |
UDPDestination.getInbuiltBackChannel(Message inMessage) |
void |
UDPConduit.prepare(Message message) |
| Modifier and Type | Method and Description |
|---|---|
protected OutputStream |
AhcWebSocketConduit.createOutputStream(Message message,
boolean needToCacheRequest,
boolean isChunking,
int chunkThreshold) |
protected void |
AhcWebSocketConduit.setupConnection(Message message,
Address address,
HTTPClientPolicy csPolicy) |
protected void |
AhcWebSocketConduit.AhcWebSocketWrappedOutputStream.updateResponseHeaders(Message inMessage) |
| Constructor and Description |
|---|
AhcWebSocketWrappedOutputStream(Message message,
boolean possibleRetransmit,
boolean isChunking,
int chunkThreshold,
String conduitName,
URI url) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AtmosphereWebSocketServletDestination.setupMessage(Message inMessage,
javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp) |
| 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 abstract void |
AbstractValidationInterceptor.handleValidation(Message message,
Object resourceInstance,
Method method,
List<Object> arguments) |
protected void |
BeanValidationOutInterceptor.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 |
|---|---|
protected String |
MAPAggregatorImpl.getActionUri(Message message,
boolean checkMessage) |
void |
MAPAggregatorImpl.handleFault(Message message)
Invoked when unwinding normal interceptor chain when a fault occurred.
|
void |
MAPAggregatorImpl.handleMessage(Message message)
Invoked for normal processing of inbound and outbound messages.
|
protected boolean |
MAPAggregatorImpl.mediate(Message message,
boolean isFault)
Mediate message flow.
|
void |
MAPAggregatorImpl.InterposedMessageObserver.onMessage(Message inMessage)
Called for an incoming message.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MEXInInterceptor.handleMessage(Message message) |
| 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(Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicy.getFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getInFaultInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getInFaultInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getInInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getInInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
EffectivePolicy.getInterceptors() |
List<Interceptor<? extends Message>> |
EffectivePolicyImpl.getInterceptors() |
List<Interceptor<? extends Message>> |
EndpointPolicyImpl.getInterceptors(Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicy.getInterceptors(Message m) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getInterceptorsForAlternative(Collection<? extends org.apache.neethi.Assertion> alterative,
boolean out,
boolean fault) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getInterceptorsForAlternative(Collection<? extends org.apache.neethi.Assertion> alternative,
boolean out,
boolean fault) |
protected List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getInterceptorsForAssertion(QName qn,
boolean out,
boolean fault) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getOutFaultInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getOutFaultInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistry.getOutInterceptorsForAssertion(QName qn) |
List<Interceptor<? extends Message>> |
PolicyInterceptorProviderRegistryImpl.getOutInterceptorsForAssertion(QName qn) |
| Modifier and Type | Method and Description |
|---|---|
void |
PolicyUtils.WrappedAssertor.assertMessage(Message message) |
void |
Assertor.assertMessage(Message message) |
<T> void |
PolicyDataEngineImpl.assertMessage(Message message,
T confPol,
PolicyCalculator<T> policyCalculator) |
boolean |
PolicyInterceptorProvider.configurationPresent(Message msg,
org.apache.neethi.Assertion assertion)
Return false if the message does not contain enough contextual configuration to preemtively
support the given assertion.
|
boolean |
AbstractPolicyInterceptorProvider.configurationPresent(Message msg,
org.apache.neethi.Assertion assertion) |
protected BindingFaultInfo |
AbstractPolicyInterceptor.getBindingFaultInfo(Message msg,
Exception ex,
BindingOperationInfo boi) |
EndpointPolicy |
PolicyEngineImpl.getClientEndpointPolicy(EndpointInfo ei,
Conduit conduit,
Message m) |
EndpointPolicy |
PolicyEngine.getClientEndpointPolicy(EndpointInfo ei,
Conduit conduit,
Message msg) |
<T> T |
PolicyDataEngineImpl.getClientEndpointPolicy(Message m,
EndpointInfo ei,
Conduit c,
PolicyCalculator<T> policyCalculator) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveClientFaultPolicy(EndpointInfo ei,
BindingOperationInfo boi,
BindingFaultInfo bfi,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveClientFaultPolicy(EndpointInfo ei,
BindingOperationInfo boi,
BindingFaultInfo bfi,
Message m) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveClientRequestPolicy(EndpointInfo ei,
BindingOperationInfo boi,
Conduit c,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveClientRequestPolicy(EndpointInfo ei,
BindingOperationInfo boi,
Conduit c,
Message m) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveClientResponsePolicy(EndpointInfo ei,
BindingOperationInfo boi,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveClientResponsePolicy(EndpointInfo ei,
BindingOperationInfo boi,
Message m) |
org.apache.neethi.Policy |
PolicyProvider.getEffectivePolicy(BindingFaultInfo bfi,
Message m) |
org.apache.neethi.Policy |
PolicyProvider.getEffectivePolicy(BindingMessageInfo bmi,
Message m) |
org.apache.neethi.Policy |
PolicyProvider.getEffectivePolicy(BindingOperationInfo bi,
Message m) |
org.apache.neethi.Policy |
PolicyProvider.getEffectivePolicy(EndpointInfo ei,
Message m) |
org.apache.neethi.Policy |
PolicyProvider.getEffectivePolicy(ServiceInfo si,
Message m) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveServerFaultPolicy(EndpointInfo ei,
BindingOperationInfo boi,
BindingFaultInfo bfi,
Destination d,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveServerFaultPolicy(EndpointInfo ei,
BindingOperationInfo boi,
BindingFaultInfo bfi,
Destination d,
Message m) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveServerRequestPolicy(EndpointInfo ei,
BindingOperationInfo boi,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveServerRequestPolicy(EndpointInfo ei,
BindingOperationInfo boi,
Message m) |
EffectivePolicy |
PolicyEngineImpl.getEffectiveServerResponsePolicy(EndpointInfo ei,
BindingOperationInfo boi,
Destination d,
List<List<org.apache.neethi.Assertion>> incoming,
Message m) |
EffectivePolicy |
PolicyEngine.getEffectiveServerResponsePolicy(EndpointInfo ei,
BindingOperationInfo boi,
Destination d,
List<List<org.apache.neethi.Assertion>> incoming,
Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicyImpl.getFaultInterceptors(Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicy.getFaultInterceptors(Message m) |
Collection<org.apache.neethi.Assertion> |
EndpointPolicyImpl.getFaultVocabulary(Message m) |
Collection<org.apache.neethi.Assertion> |
EndpointPolicy.getFaultVocabulary(Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicyImpl.getInterceptors(Message m) |
List<Interceptor<? extends Message>> |
EndpointPolicy.getInterceptors(Message m) |
<T> T |
PolicyDataEngineImpl.getPolicy(Message message,
T confPolicy,
PolicyCalculator<T> intersector) |
EndpointPolicy |
PolicyEngineImpl.getServerEndpointPolicy(EndpointInfo ei,
Destination destination,
Message m) |
EndpointPolicy |
PolicyEngine.getServerEndpointPolicy(EndpointInfo ei,
Destination destination,
Message msg) |
<T> T |
PolicyDataEngineImpl.getServerEndpointPolicy(Message m,
EndpointInfo ei,
Destination d,
PolicyCalculator<T> policyCalculator) |
protected Collection<org.apache.neethi.Assertion> |
EndpointPolicyImpl.getSupportedAlternatives(Message msg) |
protected Collection<org.apache.neethi.Assertion> |
EffectivePolicyImpl.getSupportedAlternatives(PolicyEngine engine,
org.apache.neethi.Policy p,
Message m) |
protected void |
AbstractPolicyInterceptor.getTransportAssertions(Message message) |
Collection<org.apache.neethi.Assertion> |
EndpointPolicyImpl.getVocabulary(Message m) |
Collection<org.apache.neethi.Assertion> |
EndpointPolicy.getVocabulary(Message m) |
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 |
PolicyOutInterceptor.handle(Message msg) |
protected void |
PolicyVerificationOutInterceptor.handle(Message message)
Checks if all assertions in the chosen alternative have been asserted.
|
protected abstract void |
AbstractPolicyInterceptor.handle(Message message) |
protected void |
PolicyVerificationInInterceptor.handle(Message message)
Determines the effective policy, and checks if one of its alternatives
is supported.
|
protected void |
PolicyInInterceptor.handle(Message msg) |
protected void |
ServerPolicyOutFaultInterceptor.handle(Message msg) |
void |
AbstractPolicyInterceptor.handleMessage(Message message) |
void |
EffectivePolicyImpl.initialise(EndpointInfo ei,
BindingOperationInfo boi,
BindingFaultInfo bfi,
PolicyEngine engine,
Assertor assertor,
Message m) |
void |
EffectivePolicyImpl.initialise(EndpointInfo ei,
BindingOperationInfo boi,
PolicyEngine engine,
Assertor assertor,
boolean requestor,
boolean request,
Message m) |
void |
EffectivePolicyImpl.initialise(EndpointInfo ei,
BindingOperationInfo boi,
PolicyEngine engine,
Assertor assertor,
List<List<org.apache.neethi.Assertion>> incoming,
Message m) |
void |
EffectivePolicyImpl.initialise(EndpointInfo ei,
BindingOperationInfo boi,
PolicyEngine engine,
boolean requestor,
boolean request,
Message m) |
void |
EffectivePolicyImpl.initialise(EndpointPolicy epi,
PolicyEngine engine,
boolean inbound,
boolean fault,
Message m) |
void |
EffectivePolicyImpl.initialise(EndpointPolicy epi,
PolicyEngine engine,
boolean inbound,
Message m) |
void |
EndpointPolicyImpl.initialize(Message m) |
Collection<org.apache.neethi.Assertion> |
AlternativeSelector.selectAlternative(org.apache.neethi.Policy policy,
PolicyEngine engine,
Assertor assertor,
List<List<org.apache.neethi.Assertion>> request,
Message msg) |
boolean |
PolicyEngineImpl.supportsAlternative(Collection<? extends org.apache.neethi.PolicyComponent> alternative,
Assertor assertor,
Message m)
Check if a given list of assertions can potentially be supported by
interceptors or by an already installed assertor (a conduit or transport
that implements the Assertor interface).
|
boolean |
PolicyEngine.supportsAlternative(Collection<? extends org.apache.neethi.PolicyComponent> alterative,
Assertor assertor,
Message m) |
EndpointPolicy |
EndpointPolicyImpl.updatePolicy(org.apache.neethi.Policy p,
Message msg) |
EndpointPolicy |
EndpointPolicy.updatePolicy(org.apache.neethi.Policy p,
Message msg) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.neethi.Policy |
ServiceModelPolicyProvider.getEffectivePolicy(BindingFaultInfo bfi,
Message m) |
org.apache.neethi.Policy |
ServiceModelPolicyProvider.getEffectivePolicy(BindingMessageInfo bmi,
Message m) |
org.apache.neethi.Policy |
ServiceModelPolicyProvider.getEffectivePolicy(BindingOperationInfo bi,
Message m) |
org.apache.neethi.Policy |
ServiceModelPolicyProvider.getEffectivePolicy(EndpointInfo ei,
Message m) |
org.apache.neethi.Policy |
ServiceModelPolicyProvider.getEffectivePolicy(ServiceInfo si,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.neethi.Policy |
ExternalAttachmentProvider.getEffectivePolicy(BindingFaultInfo bfi,
Message m) |
org.apache.neethi.Policy |
ExternalAttachmentProvider.getEffectivePolicy(BindingMessageInfo bmi,
Message m) |
org.apache.neethi.Policy |
ExternalAttachmentProvider.getEffectivePolicy(BindingOperationInfo boi,
Message m) |
org.apache.neethi.Policy |
ExternalAttachmentProvider.getEffectivePolicy(EndpointInfo ei,
Message m) |
org.apache.neethi.Policy |
ExternalAttachmentProvider.getEffectivePolicy(ServiceInfo si,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.neethi.Policy |
Wsdl11AttachmentPolicyProvider.getEffectivePolicy(BindingFaultInfo bfi,
Message m) |
org.apache.neethi.Policy |
Wsdl11AttachmentPolicyProvider.getEffectivePolicy(BindingMessageInfo bmi,
Message m)
The effective policy for a specific WSDL message (input or output) is calculated
in relation to a specific port, and includes the element policy of the wsdl:message
element that defines the message's type merged with the element policy of the
wsdl11:binding and wsdl11:portType message definitions that describe the message.
|
org.apache.neethi.Policy |
Wsdl11AttachmentPolicyProvider.getEffectivePolicy(BindingOperationInfo bi,
Message m)
The effective policy for a WSDL operation policy subject is calculated in relation to a
specific port, and includes the element policy of the wsdl11:portType/wsdl11:operation
element that defines the operation merged with that of the corresponding
wsdl11:binding/wsdl11:operation element.
|
org.apache.neethi.Policy |
Wsdl11AttachmentPolicyProvider.getEffectivePolicy(EndpointInfo ei,
Message m)
The effective policy for a WSDL endpoint policy subject includes the element policy of the
wsdl11:port element that defines the endpoint merged with the element policy of the
referenced wsdl11:binding element and the element policy of the referenced wsdl11:portType
element that defines the interface of the endpoint.
|
org.apache.neethi.Policy |
Wsdl11AttachmentPolicyProvider.getEffectivePolicy(ServiceInfo si,
Message m) |
| Modifier and Type | Method and Description |
|---|---|
void |
MTOMPolicyInterceptor.handleMessage(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Collection<org.apache.neethi.Assertion> |
FirstAlternativeSelector.selectAlternative(org.apache.neethi.Policy policy,
PolicyEngine engine,
Assertor assertor,
List<List<org.apache.neethi.Assertion>> request,
Message msg) |
Collection<org.apache.neethi.Assertion> |
MinimalAlternativeSelector.selectAlternative(org.apache.neethi.Policy policy,
PolicyEngine engine,
Assertor assertor,
List<List<org.apache.neethi.Assertion>> request,
Message msg) |
Collection<org.apache.neethi.Assertion> |
MaximalAlternativeSelector.selectAlternative(org.apache.neethi.Policy policy,
PolicyEngine engine,
Assertor assertor,
List<List<org.apache.neethi.Assertion>> request,
Message msg) |
| 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) |
protected void |
RMOutInterceptor.addAckRequest(Message msg,
RMProperties rmpsIn,
SourceSequence seq,
SequenceType sequence)
Add AcknowledgementRequested to message if needed.
|
void |
RetransmissionQueue.addUnacknowledged(Message message)
Accepts a new message for possible future retransmission.
|
void |
RedeliveryQueue.addUndelivered(Message message)
Accepts a failed message for possible future redelivery.
|
Object |
Servant.closeSequence(Message message) |
Fault |
BindingFaultFactory.createFault(SequenceFault sf,
Message msg) |
Destination |
RMManager.getDestination(Message message) |
RMConfiguration |
RMManager.getEffectiveConfiguration(Message msg)
Get configuration after applying policies.
|
static ProtocolVariation |
RMContextUtils.getProtocolVariation(Message message) |
RMEndpoint |
RMManager.getReliableEndpoint(Message message) |
PhaseInterceptorChain |
RMManager.getRetransmitChain(Message msg)
Get interceptor chain for retransmitting a message.
|
SourceSequence |
RMManager.getSequence(Identifier inSeqId,
Message message,
AddressingProperties maps) |
Source |
RMManager.getSource(Message message) |
void |
RMDeliveryInterceptor.handle(Message message) |
protected abstract void |
AbstractRMInterceptor.handle(Message message) |
protected void |
RMOutInterceptor.handle(Message msg) |
protected void |
RMInInterceptor.handle(Message message) |
protected void |
RMCaptureInInterceptor.handle(Message message) |
protected void |
RMCaptureOutInterceptor.handle(Message msg) |
void |
RMEndpoint.handleAccept(String ssid,
long number,
Message msg)
Handle message accepted for source sequence.
|
void |
RMEndpoint.handleAcknowledgment(String ssid,
long number,
Message msg)
Handle message acknowledgment for source sequence.
|
void |
RMInInterceptor.handleFault(Message message) |
void |
RetransmissionInterceptor.handleFault(Message message) |
void |
AbstractRMInterceptor.handleMessage(Message msg) |
void |
RetransmissionInterceptor.handleMessage(Message message) |
void |
RMManager.initializeInterceptorChain(Message msg)
Clones and saves the interceptor chain the first time this is called, so that it can be used for retransmission.
|
protected boolean |
AbstractRMInterceptor.isRMPolicyEnabled(Message msg) |
static boolean |
RMContextUtils.isServerSide(Message message)
Determine if message is currently being processed on server side.
|
static AddressingProperties |
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.setProtocolVariation(Message message,
ProtocolVariation protocol) |
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.
|
Object |
Servant.terminateSequence(Message message) |
| Modifier and Type | Method and Description |
|---|---|
static void |
PersistenceUtils.decodeRMContent(RMMessage rmmsg,
Message msg) |
static void |
PersistenceUtils.encodeRMContent(RMMessage rmmsg,
Message msg,
InputStream msgContent) |
| Modifier and Type | Method and Description |
|---|---|
static RMConfiguration |
RMPolicyUtilities.getRMConfiguration(RMConfiguration 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 |
RedeliveryQueueImpl.RedeliverCandidate.getMessage() |
protected Message |
RetransmissionQueueImpl.ResendCandidate.getMessage() |
| Modifier and Type | Method and Description |
|---|---|
void |
RetransmissionQueueImpl.addUnacknowledged(Message message) |
void |
RedeliveryQueueImpl.addUndelivered(Message message) |
protected RetransmissionQueueImpl.ResendCandidate |
RetransmissionQueueImpl.cacheUnacknowledged(Message message)
Accepts a new resend candidate.
|
protected RedeliveryQueueImpl.RedeliverCandidate |
RedeliveryQueueImpl.cacheUndelivered(Message message)
Accepts a new resend candidate.
|
Fault |
SoapFaultFactory.createFault(SequenceFault sf,
Message msg) |
protected RetransmissionQueueImpl.ResendCandidate |
RetransmissionQueueImpl.createResendCandidate(Message message) |
void |
RetransmissionQueueImpl.CopyOutInterceptor.handleMessage(Message message) |
void |
RetransmissionQueueImpl.Resender.resend(Message message,
boolean requestAcknowledge)
Resend mechanics.
|
| Constructor and Description |
|---|
RedeliverCandidate(Message m) |
ResendCandidate(Message m) |
| 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) |
TokenStore |
EHCacheTokenStoreFactory.newTokenStore(String key,
Message message) |
TokenStore |
MemoryTokenStoreFactory.newTokenStore(String key,
Message message) |
abstract TokenStore |
TokenStoreFactory.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,
org.apache.wss4j.policy.model.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,
boolean retrieveTokenFromEndpoint)
Retrieve a cached STS token.
|
SecurityToken |
DefaultSTSTokenCacher.retrieveToken(Message message,
boolean retrieveTokenFromEndpoint) |
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,
boolean storeTokenInEndpoint)
Store a token in the cache.
|
void |
DefaultSTSTokenCacher.storeToken(Message message,
SecurityToken securityToken,
boolean storeTokenInEndpoint) |
org.apache.wss4j.dom.validate.Credential |
STSTokenValidator.validateWithSTS(org.apache.wss4j.dom.validate.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>> |
AbstractWSS4JInterceptor.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
PolicyBasedWSS4JOutInterceptor.PolicyBasedWSS4JOutInterceptorInternal.getAdditionalInterceptors() |
Collection<PhaseInterceptor<? extends Message>> |
AbstractWSS4JStaxInterceptor.getAdditionalInterceptors() |
| Modifier and Type | Method and Description |
|---|---|
static void |
WSS4JTokenConverter.convertToken(Message msg,
Principal p) |
static org.apache.wss4j.common.crypto.PasswordEncryptor |
WSS4JUtils.getPasswordEncryptor(Message message) |
static long |
WSS4JUtils.getSecurityTokenLifetime(Message message)
Get the security token lifetime value (in milliseconds).
|
static org.apache.wss4j.common.crypto.Crypto |
WSS4JUtils.loadCryptoFromPropertiesFile(Message message,
String propFilename,
ClassLoader classLoader,
org.apache.wss4j.common.crypto.PasswordEncryptor passwordEncryptor) |
static String |
WSS4JUtils.parseAndStoreStreamingSecurityToken(org.apache.xml.security.stax.securityToken.SecurityToken securityToken,
Message message) |
| Constructor and Description |
|---|
AttachmentCallbackHandler(Message message) |
| Modifier and Type | Method and Description |
|---|---|
Message |
PolicyValidatorParameters.getMessage() |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
AbstractBindingPolicyValidator.checkProperties(org.apache.wss4j.policy.model.AbstractSymmetricAsymmetricBinding binding,
AssertionInfo ai,
AssertionInfoMap aim,
org.apache.wss4j.dom.handler.WSHandlerResult results,
List<org.apache.wss4j.dom.engine.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(org.apache.wss4j.policy.model.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,
org.apache.wss4j.dom.handler.WSHandlerResult results,
List<org.apache.wss4j.dom.engine.WSSecurityEngineResult> signedResults,
Message message)
Validate a Timestamp
|
| Modifier and Type | Method and Description |
|---|---|
void |
BareInInterceptor.handleMessage(Message message) |
void |
BareOutInterceptor.handleMessage(Message message) |
void |
AbstractEndpointSelectionInterceptor.handleMessage(Message message) |
void |
DocLiteralInInterceptor.handleMessage(Message message) |
void |
WrappedOutInterceptor.handleMessage(Message message) |
void |
WrappedOutInterceptor.WrappedOutEndingInterceptor.handleMessage(Message message) |
protected abstract Endpoint |
AbstractEndpointSelectionInterceptor.selectEndpoint(Message message,
Set<Endpoint> eps)
Select an Endpoint which will be used for the rest of the invocation.
|
protected boolean |
DocLiteralInInterceptor.shouldWrapParameters(MessageInfo msgInfo,
Message message) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.wss4j.common.crypto.Crypto |
CryptoProviderFactory.create(Message message)
Create with merlin fallback settings retrieved from cxf message
|
| Modifier and Type | Method and Description |
|---|---|
org.apache.wss4j.common.crypto.Crypto |
XkmsCryptoProviderFactory.create(Message message) |
Apache CXF