Modifier and Type | Method and Description |
---|---|
Object |
FactoryType.DEFAULT.create(Exchange e) |
void |
FactoryType.DEFAULT.release(Exchange e,
Object o) |
Modifier and Type | Method and Description |
---|---|
protected Message |
ColocOutInterceptor.getInBoundMessage(Exchange ex) |
static InterceptorChain |
ColocUtil.getInInterceptorChain(Exchange ex,
SortedSet<Phase> phases) |
static InterceptorChain |
ColocUtil.getOutInterceptorChain(Exchange ex,
SortedSet<Phase> phases) |
protected void |
ColocInFaultObserver.initializeInterceptors(Exchange ex,
PhaseInterceptorChain chain) |
protected void |
ColocOutInterceptor.invokeInboundChain(Exchange ex,
Endpoint ep) |
void |
ColocOutInterceptor.setExchangeProperties(Exchange exchange,
Endpoint ep) |
protected void |
ColocMessageObserver.setExchangeProperties(Exchange exchange,
Message m) |
protected void |
ColocMessageObserver.setOutBoundMessage(Exchange from,
Exchange to) |
Modifier and Type | Method and Description |
---|---|
void |
FailoverTargetSelector.complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
protected void |
FailoverTargetSelector.doComplete(Exchange exchange) |
List<String> |
AbstractStaticFailoverStrategy.getAlternateAddresses(Exchange exchange)
Get the alternate addresses for this invocation.
|
List<String> |
FailoverStrategy.getAlternateAddresses(Exchange exchange)
Get the alternate addresses for this invocation.
|
List<Endpoint> |
RetryStrategy.getAlternateEndpoints(Exchange exchange) |
List<Endpoint> |
AbstractStaticFailoverStrategy.getAlternateEndpoints(Exchange exchange)
Get the alternate endpoints for this invocation.
|
List<Endpoint> |
FailoverStrategy.getAlternateEndpoints(Exchange exchange)
Get the alternate endpoints for this invocation.
|
protected List<Endpoint> |
AbstractStaticFailoverStrategy.getEndpoints(Exchange exchange,
boolean acceptCandidatesWithSameAddress)
Get the endpoints for this invocation.
|
protected Endpoint |
LoadDistributorTargetSelector.getFailoverTarget(Exchange exchange,
FailoverTargetSelector.InvocationContext invocation)
Get the failover target endpoint, if a suitable one is available.
|
protected Endpoint |
FailoverTargetSelector.getFailoverTarget(Exchange exchange,
FailoverTargetSelector.InvocationContext invocation)
Get the failover target endpoint, if a suitable one is available.
|
protected Endpoint |
CircuitBreakerTargetSelector.getFailoverTarget(Exchange exchange,
FailoverTargetSelector.InvocationContext invocation) |
protected String |
FailoverTargetSelector.getInvocationKey(Exchange e) |
protected boolean |
FailoverTargetSelector.performFailover(Exchange exchange,
FailoverTargetSelector.InvocationContext invocation) |
protected boolean |
LoadDistributorTargetSelector.requiresFailover(Exchange exchange,
Exception ex) |
protected boolean |
FailoverTargetSelector.requiresFailover(Exchange exchange,
Exception ex)
Check if the exchange is suitable for a failover.
|
protected void |
FailoverTargetSelector.setupExchangeExceptionProperties(Exchange ex) |
protected List<String> |
FailoverTargetSelector.updateContextAlternatives(Exchange exchange,
FailoverTargetSelector.InvocationContext invocation)
Fetches and updates the alternative address or/and alternative endpoints
(depending on the strategy) for current invocation context.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractConduitSelector.complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
void |
NullConduitSelector.complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
void |
PreexistingConduitSelector.complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
void |
ConduitSelector.complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
protected Conduit |
AbstractConduitSelector.createConduit(Message message,
Exchange exchange,
ConduitInitiator conduitInitiator) |
protected Exception |
ClientImpl.getException(Exchange exchange) |
Object[] |
ClientImpl.invoke(BindingOperationInfo oi,
Object[] params,
Exchange exchange) |
Object[] |
Client.invoke(BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange)
Invokes an operation synchronously
|
Object[] |
Retryable.invoke(BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange) |
Object[] |
ClientImpl.invoke(BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange) |
void |
Client.invoke(ClientCallback callback,
BindingOperationInfo oi,
Object[] params,
Exchange exchange)
Invokes an operation asynchronously
|
void |
ClientImpl.invoke(ClientCallback callback,
BindingOperationInfo oi,
Object[] params,
Exchange exchange) |
void |
Client.invoke(ClientCallback callback,
BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange)
Invokes an operation asynchronously
|
void |
ClientImpl.invoke(ClientCallback callback,
BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange) |
protected Object[] |
ClientImpl.processResult(Message message,
Exchange exchange,
BindingOperationInfo oi,
Map<String,Object> resContext) |
protected void |
ClientImpl.setExchangeProperties(Exchange exchange,
Endpoint endpoint,
BindingOperationInfo boi) |
protected void |
ClientImpl.waitResponse(Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
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 BindingOperationInfo |
AbstractInDatabindingInterceptor.getBindingOperationInfo(Exchange exchange,
QName name,
boolean client)
Returns a BindingOperationInfo if the operation is indentified as
a wrapped method, return null if it is not a wrapped method
(i.e., it is a bare method)
|
static InterceptorChain |
OutgoingChainInterceptor.getOutInterceptorChain(Exchange ex) |
protected void |
OutFaultChainInitiatorObserver.initializeInterceptors(Exchange ex,
PhaseInterceptorChain chain) |
protected void |
InFaultChainInitiatorObserver.initializeInterceptors(Exchange ex,
PhaseInterceptorChain chain) |
protected void |
AbstractFaultChainInitiatorObserver.initializeInterceptors(Exchange ex,
PhaseInterceptorChain chain) |
protected void |
AbstractOutDatabindingInterceptor.writeParts(Message message,
Exchange exchange,
BindingOperationInfo operation,
MessageContentsList objs,
List<MessagePartInfo> parts) |
Modifier and Type | Method and Description |
---|---|
protected Object |
JAXRSInvoker.getActualServiceObject(Exchange exchange,
Object rootInstance) |
Object |
JAXRSInvoker.getServiceObject(Exchange exchange) |
Object |
JAXRSInvoker.invoke(Exchange exchange,
Object request) |
Object |
JAXRSInvoker.invoke(Exchange exchange,
Object request,
Object resourceObject) |
Modifier and Type | Method and Description |
---|---|
protected Exchange |
AbstractClient.createExchange(Message m,
Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractClient.completeExchange(Exchange exchange,
boolean proxy) |
protected Exchange |
AbstractClient.createExchange(Message m,
Exchange exchange) |
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) |
protected javax.ws.rs.core.Response |
WebClient.doChainedInvocation(String httpMethod,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
Object body,
Class<?> requestClass,
Type inType,
Annotation[] inAnns,
Class<?> respClass,
Type outType,
Exchange exchange,
Map<String,Object> invContext) |
protected Object |
ClientProxyImpl.doChainedInvocation(URI uri,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
OperationResourceInfo ori,
Object[] methodParams,
Object body,
int bodyIndex,
Exchange exchange,
Map<String,Object> invocationContext) |
protected Object[] |
AbstractClient.retryInvoke(BindingOperationInfo oi,
Object[] params,
Map<String,Object> context,
Exchange exchange) |
protected Object |
ClientProxyImpl.retryInvoke(URI newRequestURI,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
Object body,
Exchange exchange,
Map<String,Object> invContext) |
protected Object |
WebClient.retryInvoke(URI newRequestURI,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
Object body,
Exchange exchange,
Map<String,Object> invContext) |
protected abstract Object |
AbstractClient.retryInvoke(URI newRequestURI,
javax.ws.rs.core.MultivaluedMap<String,String> headers,
Object body,
Exchange exchange,
Map<String,Object> invContext) |
protected void |
AbstractClient.setAsyncMessageObserverIfNeeded(Exchange exchange) |
protected void |
AbstractClient.setContexts(Message message,
Exchange exchange,
Map<String,Object> context,
boolean proxy) |
protected javax.ws.rs.core.Response.ResponseBuilder |
AbstractClient.setResponseBuilder(Message outMessage,
Exchange exchange) |
protected void |
AbstractClient.waitForResponseCode(Exchange exchange) |
Constructor and Description |
---|
OutboundSseEventBodyWriter(ServerProviderFactory factory,
Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
static Type |
InjectionUtils.getGenericResponseType(Method invoked,
Class<?> serviceCls,
Object targetObject,
Class<?> targetType,
Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
Object |
JAXRSBeanValidationInvoker.invoke(Exchange exchange,
Object serviceObject,
Method m,
List<Object> params) |
Modifier and Type | Method and Description |
---|---|
protected Method |
AbstractJAXWSMethodInvoker.adjustMethodAndParams(Method mOriginal,
Exchange ex,
List<Object> params,
Class<?> serviceObjectClass) |
protected Object |
AbstractJAXWSMethodInvoker.invoke(Exchange exchange,
Object serviceObject,
Method m,
List<Object> params) |
protected Object |
JAXWSMethodInvoker.invoke(Exchange exchange,
Object serviceObject,
Method m,
List<Object> params) |
protected Object |
JAXWSMethodInvoker.performInvocation(Exchange exchange,
Object serviceObject,
Method m,
Object[] paramArray) |
protected void |
AbstractJAXWSMethodInvoker.updateHeader(Exchange exchange,
MessageContext ctx) |
protected void |
AbstractJAXWSMethodInvoker.updateWebServiceContext(Exchange exchange,
MessageContext ctx) |
Constructor and Description |
---|
WrappedMessageContext(Map<String,Object> m,
Exchange ex,
MessageContext.Scope defScope) |
Modifier and Type | Method and Description |
---|---|
protected QName |
AbstractJAXWSHandlerInterceptor.getOpQName(Exchange ex,
Object data) |
protected void |
AbstractJAXWSHandlerInterceptor.setupBindingOperationInfo(Exchange exch,
Object data) |
Modifier and Type | Method and Description |
---|---|
protected QName |
LogicalHandlerInInterceptor.getOpQName(Exchange ex,
Object data) |
Modifier and Type | Method and Description |
---|---|
protected QName |
SOAPHandlerInterceptor.getOpQName(Exchange ex,
Object data) |
Modifier and Type | Method and Description |
---|---|
Object |
MDBInvoker.getServiceObject(Exchange context) |
Object |
DispatchMDBInvoker.getServiceObject(Exchange context) |
void |
MDBInvoker.releaseServiceObject(Exchange context,
Object obj) |
void |
DispatchMDBInvoker.releaseServiceObject(Exchange context,
Object obj) |
Modifier and Type | Method and Description |
---|---|
Object |
EJBInvoker.getServiceObject(Exchange context) |
Modifier and Type | Method and Description |
---|---|
Exchange |
MessageHandlingTimeRecorder.getHandleExchange() |
Constructor and Description |
---|
MessageHandlingTimeRecorder(Exchange ex) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMessageResponseTimeInterceptor.beginHandlingMessage(Exchange ex) |
protected void |
AbstractMessageResponseTimeInterceptor.endHandlingMessage(Exchange ex) |
protected ObjectName |
AbstractMessageResponseTimeInterceptor.getOperationCounterName(Exchange ex,
ObjectName sericeCounterName) |
protected ObjectName |
AbstractMessageResponseTimeInterceptor.getServiceCounterName(Exchange ex) |
protected boolean |
AbstractMessageResponseTimeInterceptor.isServiceCounterEnabled(Exchange ex) |
protected void |
AbstractMessageResponseTimeInterceptor.setOneWayMessage(Exchange ex) |
Modifier and Type | Class and Description |
---|---|
class |
ExchangeImpl |
Modifier and Type | Method and Description |
---|---|
Exchange |
Message.getExchange() |
Exchange |
AbstractWrappedMessage.getExchange() |
Exchange |
MessageImpl.getExchange() |
Modifier and Type | Method and Description |
---|---|
void |
Message.setExchange(Exchange exchange) |
void |
AbstractWrappedMessage.setExchange(Exchange exchange) |
void |
MessageImpl.setExchange(Exchange e) |
Modifier and Type | Method and Description |
---|---|
void |
MetricsContext.start(Exchange m)
Will be called at the start of invoke (or when added to a started MessageMetrics).
|
void |
MetricsContext.stop(long timeInNS,
long inSize,
long outSize,
Exchange exchange)
Called when the invocation is complete.
|
Constructor and Description |
---|
ExchangeMetrics(Exchange e) |
Modifier and Type | Method and Description |
---|---|
void |
CodahaleMetricsContext.start(Exchange ex) |
void |
CodahaleMetricsContext.stop(long timeInNS,
long inSize,
long outSize,
Exchange ex) |
Modifier and Type | Method and Description |
---|---|
protected Iterable<io.micrometer.core.instrument.Tag> |
MicrometerServerMetricsContext.getAllTags(Exchange ex) |
protected Iterable<io.micrometer.core.instrument.Tag> |
MicrometerClientMetricsContext.getAllTags(Exchange ex) |
protected void |
MicrometerServerMetricsContext.record(org.apache.cxf.metrics.micrometer.MicrometerMetricsContext.TimingContext timingContext,
Exchange ex) |
protected void |
MicrometerClientMetricsContext.record(org.apache.cxf.metrics.micrometer.MicrometerMetricsContext.TimingContext timingContext,
Exchange ex) |
void |
MicrometerServerMetricsContext.start(Exchange ex) |
void |
MicrometerClientMetricsContext.start(Exchange ex) |
void |
MicrometerServerMetricsContext.stop(long timeInNS,
long inSize,
long outSize,
Exchange ex) |
void |
MicrometerClientMetricsContext.stop(long timeInNS,
long inSize,
long outSize,
Exchange ex) |
Modifier and Type | Method and Description |
---|---|
Iterable<io.micrometer.core.instrument.Tag> |
TagsCustomizer.getAdditionalTags(Exchange ex,
boolean client) |
Class<?> |
ExceptionClassProvider.getExceptionClass(Exchange ex,
boolean client) |
Class<?> |
DefaultExceptionClassProvider.getExceptionClass(Exchange ex,
boolean client) |
Iterable<io.micrometer.core.instrument.Tag> |
TagsProvider.getTags(Exchange ex,
boolean client) |
Iterable<io.micrometer.core.instrument.Tag> |
StandardTagsProvider.getTags(Exchange ex,
boolean client) |
Set<io.micrometer.core.annotation.Timed> |
DefaultTimedAnnotationProvider.getTimedAnnotations(Exchange ex,
boolean client) |
Set<io.micrometer.core.annotation.Timed> |
TimedAnnotationProvider.getTimedAnnotations(Exchange ex,
boolean client) |
Modifier and Type | Method and Description |
---|---|
Iterable<io.micrometer.core.instrument.Tag> |
JaxrsOperationTagsCustomizer.getAdditionalTags(Exchange ex,
boolean client) |
Modifier and Type | Method and Description |
---|---|
Iterable<io.micrometer.core.instrument.Tag> |
JaxwsFaultCodeTagsCustomizer.getAdditionalTags(Exchange ex,
boolean client) |
Iterable<io.micrometer.core.instrument.Tag> |
JaxwsOperationTagsCustomizer.getAdditionalTags(Exchange ex,
boolean client) |
String |
JaxwsFaultCodeProvider.getFaultCode(Exchange ex,
boolean client) |
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 Object |
OAuthInvoker.performInvocation(Exchange exchange,
Object serviceObject,
Method m,
Object[] paramArray) |
Modifier and Type | Method and Description |
---|---|
protected Method |
AbstractInvoker.adjustMethodAndParams(Method m,
Exchange ex,
List<Object> params,
Class<?> serviceObjectClass) |
protected void |
AbstractInvoker.checkSuspendedInvocation(Exchange exchange,
Object serviceObject,
Method m,
List<Object> params,
Throwable t) |
Object |
SingletonFactory.create(Exchange ex)
Creates the object that will be used for the invoke
|
Object |
Factory.create(Exchange e)
Creates the object that will be used for the invoke
|
Object |
PerRequestFactory.create(Exchange ex) |
Object |
SessionFactory.create(Exchange e)
Creates the object that will be used for the invoke
|
Object |
PooledFactory.create(Exchange ex)
Creates the object that will be used for the invoke
|
protected Object |
PooledFactory.createObject(Exchange e) |
Object |
BeanInvoker.getServiceObject(Exchange ex) |
Object |
FactoryInvoker.getServiceObject(Exchange ex) |
abstract Object |
AbstractInvoker.getServiceObject(Exchange context)
Creates and returns a service object depending on the scope.
|
Object[] |
AbstractInvoker.insertExchange(Method method,
Object[] params,
Exchange context) |
Object |
AbstractInvoker.invoke(Exchange exchange,
Object o) |
Object |
Invoker.invoke(Exchange exchange,
Object o) |
protected Object |
AbstractInvoker.invoke(Exchange exchange,
Object serviceObject,
Method m,
List<Object> params) |
protected Object |
AbstractInvoker.performInvocation(Exchange exchange,
Object serviceObject,
Method m,
Object[] paramArray) |
void |
SingletonFactory.release(Exchange ex,
Object o)
Post invoke, this is called to allow the factory to release
the object, store it, etc...
|
void |
Factory.release(Exchange e,
Object o)
Post invoke, this is called to allow the factory to release
the object, store it, etc...
|
void |
PerRequestFactory.release(Exchange ex,
Object o) |
void |
SessionFactory.release(Exchange e,
Object o)
Post invoke, this is called to allow the factory to release
the object, store it, etc...
|
void |
PooledFactory.release(Exchange ex,
Object o)
Post invoke, this is called to allow the factory to release
the object, store it, etc...
|
void |
FactoryInvoker.releaseServiceObject(Exchange ex,
Object obj) |
void |
AbstractInvoker.releaseServiceObject(Exchange context,
Object obj)
Called when the invoker is done with the object.
|
Modifier and Type | Method and Description |
---|---|
Object |
SpringBeanFactory.create(Exchange e)
Creates the object that will be used for the invoke
|
void |
SpringBeanFactory.release(Exchange e,
Object o)
Post invoke, this is called to allow the factory to release
the object, store it, etc...
|
Modifier and Type | Method and Description |
---|---|
static BindingOperationInfo |
ServiceModelUtil.getOperation(Exchange exchange,
QName opName) |
static BindingOperationInfo |
ServiceModelUtil.getOperation(Exchange exchange,
String opName) |
static BindingOperationInfo |
ServiceModelUtil.getOperationForWrapperElement(Exchange exchange,
QName opName,
boolean output) |
static Service |
ServiceModelUtil.getService(Exchange exchange) |
static String |
ServiceModelUtil.getTargetNamespace(Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
Set<io.micrometer.core.annotation.Timed> |
SpringBasedTimedAnnotationProvider.getTimedAnnotations(Exchange ex,
boolean client) |
Modifier and Type | Method and Description |
---|---|
protected void |
ChainInitiationObserver.setExchangeProperties(Exchange exchange,
Message m) |
protected void |
MultipleEndpointObserver.setExchangeProperties(Exchange exchange,
Message m) |
Modifier and Type | Method and Description |
---|---|
protected void |
HTTPConduit.WrappedOutputStream.propagateConduit(Exchange exchange,
Message in) |
Modifier and Type | Method and Description |
---|---|
protected void |
JMSConduit.processReplyMessage(Exchange exchange,
javax.jms.Message jmsMessage)
Process the reply message
|
void |
JMSConduit.sendExchange(Exchange exchange,
Object request)
Send the JMS message and if the MEP is not oneway receive the response.
|
Modifier and Type | Method and Description |
---|---|
static javax.jms.Message |
JMSUtil.receive(javax.jms.Session session,
javax.jms.Destination replyToDestination,
String correlationId,
long receiveTimeout,
boolean pubSubNoLocal,
Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
static Destination |
ContextUtils.createDecoupledDestination(Exchange exchange,
org.apache.cxf.ws.addressing.EndpointReferenceType reference) |
static Message |
ContextUtils.createMessage(Exchange exchange)
Create a Binding specific Message.
|
static void |
ContextUtils.propogateReceivedMAPs(AddressingProperties inMAPs,
Exchange exchange)
Propagate inbound MAPs onto full reponse & fault messages.
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,Exchange> |
MAPCodec.uncorrelatedExchanges
REVISIT: map usage that the *same* interceptor instance
is used in all chains.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Exchange> |
MAPCodec.getUncorrelatedExchanges() |
Modifier and Type | Method and Description |
---|---|
protected Destination |
DecoupledFaultHandler.createDecoupledDestination(Exchange exchange,
org.apache.cxf.ws.addressing.EndpointReferenceType epr) |
Modifier and Type | Method and Description |
---|---|
CreateSequenceResponseType |
Proxy.createSequence(org.apache.cxf.ws.addressing.EndpointReferenceType defaultAcksTo,
org.apache.cxf.ws.addressing.RelatesToType relatesTo,
boolean isServer,
ProtocolVariation protocol,
Exchange exchange,
Map<String,Object> context) |
Object |
Servant.invoke(Exchange exchange,
Object o) |
Modifier and Type | Method and Description |
---|---|
protected BindingOperationInfo |
DocLiteralInInterceptor.getBindingOperationInfo(Exchange exchange,
QName name,
boolean client) |
Apache CXF