org.apache.hc.client5.http.observation.impl

Class ObservationAsyncExecInterceptor

java.lang.Object

org.apache.hc.client5.http.observation.impl.ObservationAsyncExecInterceptor

All Implemented Interfaces:

AsyncExecChainHandler

public final class ObservationAsyncExecInterceptor
extends Object
implements AsyncExecChainHandler

Asynchronous execution interceptor that emits Micrometer Observations around HTTP client exchanges.

The observation is started before the request is executed and stopped when the exchange completes or fails. A simple sampling predicate from ObservingOptions can disable observations for given URIs without touching Micrometer configuration.

Since:

5.6

Constructor Summary

Constructors

Constructor and Description
ObservationAsyncExecInterceptor(io.micrometer.observation.ObservationRegistry registry, ObservingOptions opts)

Method Summary

Modifier and Type	Method and Description
void	execute(HttpRequest request, AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ObservationAsyncExecInterceptor

public ObservationAsyncExecInterceptor(io.micrometer.observation.ObservationRegistry registry,
                                       ObservingOptions opts)

Method Detail

execute

public void execute(HttpRequest request,
                    AsyncEntityProducer entityProducer,
                    AsyncExecChain.Scope scope,
                    AsyncExecChain chain,
                    AsyncExecCallback asyncExecCallback)
             throws HttpException,
                    IOException

Specified by:

execute in interface AsyncExecChainHandler

Throws:

HttpException

IOException