org.springframework.data.elasticsearch.client.reactive

Interface WebClientProvider

public interface WebClientProvider

Provider for WebClients using a pre-configured scheme. This class returns WebClient for a specific endpoint and encapsulates common configuration aspects of WebClient so that code using WebClient is not required to apply further configuration to the actual client.

Client instances are typically cached allowing reuse of pooled connections if configured on the ClientHttpConnector.

Since:

3.2

Author:

Christoph Strobl, Mark Paluch

Method Summary

Modifier and Type	Method and Description
static WebClientProvider	create(String scheme) Creates a new WebClientProvider using the given scheme and a default ClientHttpConnector.
static WebClientProvider	create(String scheme, ClientHttpConnector connector) Creates a new WebClientProvider given scheme and ClientHttpConnector.
WebClient	get(InetSocketAddress endpoint) Obtain the WebClient configured with default HTTP headers and Consumer error callback for a given endpoint.
HttpHeaders	getDefaultHeaders() Obtain the HttpHeaders to be used by default.
Consumer<Throwable>	getErrorListener() Obtain the error listener to be used;
static WebClientProvider	http() Creates a new WebClientProvider using the http scheme and a default ClientHttpConnector.
WebClientProvider	withDefaultHeaders(HttpHeaders headers) Create a new instance of WebClientProvider applying the given headers by default.
WebClientProvider	withErrorListener(Consumer<Throwable> errorListener) Create a new instance of WebClientProvider calling the given Consumer on error.

Method Detail

http

static WebClientProvider http()

Creates a new WebClientProvider using the http scheme and a default ClientHttpConnector.

Returns:

the resulting WebClientProvider.

create

static WebClientProvider create(String scheme)

Creates a new WebClientProvider using the given scheme and a default ClientHttpConnector.

Parameters:

scheme - protocol scheme such as http or https.

Returns:

the resulting WebClientProvider.

create

static WebClientProvider create(String scheme,
                                @Nullable
                                ClientHttpConnector connector)

Creates a new WebClientProvider given scheme and ClientHttpConnector.

Parameters:

scheme - protocol scheme such as http or https.

connector - the HTTP connector to use. Can be null.

Returns:

the resulting WebClientProvider.

get

WebClient get(InetSocketAddress endpoint)

Obtain the WebClient configured with default HTTP headers and Consumer error callback for a given endpoint.

Returns:

the WebClient for the given endpoint.

getDefaultHeaders

HttpHeaders getDefaultHeaders()

Obtain the HttpHeaders to be used by default.

Returns:

never null. HttpHeaders.EMPTY by default.

getErrorListener

Consumer<Throwable> getErrorListener()

Obtain the error listener to be used;

Returns:

never null.

withDefaultHeaders

WebClientProvider withDefaultHeaders(HttpHeaders headers)

Create a new instance of WebClientProvider applying the given headers by default.

Parameters:

headers - must not be null.

Returns:

new instance of WebClientProvider.

withErrorListener

WebClientProvider withErrorListener(Consumer<Throwable> errorListener)

Create a new instance of WebClientProvider calling the given Consumer on error.

Parameters:

errorListener - must not be null.

Returns:

new instance of WebClientProvider.