Class JettyClientHttpConnector

java.lang.Object

org.springframework.http.client.reactive.JettyClientHttpConnector

All Implemented Interfaces:

ClientHttpConnector

public class JettyClientHttpConnector
extends Object
implements ClientHttpConnector

ClientHttpConnector for the Jetty Reactive Streams HttpClient.

Since:

5.1

Author:

Sebastien Deleuze

See Also:

• Jetty ReactiveStreams HttpClient

Constructor Summary

Constructors

Constructor	Description
JettyClientHttpConnector()	Default constructor that creates a new instance of HttpClient.
JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient)	Constructor with an initialized HttpClient.
JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient, @Nullable JettyResourceFactory resourceFactory)	Constructor with an initialized HttpClient and configures it with the given JettyResourceFactory.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<ClientHttpResponse>	connect(HttpMethod method, URI uri, Function<? super ClientHttpRequest, reactor.core.publisher.Mono<Void>> requestCallback)	Connect to the origin server using the given HttpMethod and URI and apply the given requestCallback when the HTTP request of the underlying API can be initialized and written to.
void	setBufferFactory(JettyDataBufferFactory bufferFactory)	Set the buffer factory to use.
void	setCookieParser(ResponseCookie.Parser parser)	Customize the parsing of response cookies.

Methods inherited from class Object

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

Constructor Details

JettyClientHttpConnector

public JettyClientHttpConnector()

Default constructor that creates a new instance of HttpClient.

JettyClientHttpConnector

public JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient)

Constructor with an initialized HttpClient.

JettyClientHttpConnector

public JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient,
 @Nullable JettyResourceFactory resourceFactory)

Constructor with an initialized HttpClient and configures it with the given JettyResourceFactory.

Parameters:

httpClient - the HttpClient to use

resourceFactory - the JettyResourceFactory to use

Since:

5.2

Method Details

setBufferFactory

public void setBufferFactory(JettyDataBufferFactory bufferFactory)

Set the buffer factory to use.

setCookieParser

public void setCookieParser(ResponseCookie.Parser parser)

Customize the parsing of response cookies.

By default, HttpCookie.parse(String) is used, and additionally the sameSite attribute is parsed and set.

Parameters:

parser - the parser to use

Since:

7.0

connect

public reactor.core.publisher.Mono<ClientHttpResponse> connect(HttpMethod method,
 URI uri,
 Function<? super ClientHttpRequest, reactor.core.publisher.Mono<Void>> requestCallback)

Description copied from interface: ClientHttpConnector

Connect to the origin server using the given HttpMethod and URI and apply the given requestCallback when the HTTP request of the underlying API can be initialized and written to.

Specified by:

connect in interface ClientHttpConnector

Parameters:

method - the HTTP request method

uri - the HTTP request URI

requestCallback - a function that prepares and writes to the request, returning a publisher that signals when it's done writing. Implementations can return a Mono<Void> by calling ReactiveHttpOutputMessage.writeWith(Publisher) or ReactiveHttpOutputMessage.setComplete().

Returns:

publisher for the ClientHttpResponse