Class JettyClientHttpConnector
- java.lang.Object
- org.springframework.http.client.reactive.JettyClientHttpConnector
- All Implemented Interfaces:
ClientHttpConnector
public class JettyClientHttpConnector extends Object implements ClientHttpConnector
ClientHttpConnectorfor 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 ofHttpClient.JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient)Constructor with an initializedHttpClient.JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient, JettyResourceFactory resourceFactory)Constructor with an initializedHttpClientand configures it with the givenJettyResourceFactory.JettyClientHttpConnector(JettyResourceFactory resourceFactory, Consumer<org.eclipse.jetty.client.HttpClient> customizer)Deprecated.as of 5.2, in favor ofJettyClientHttpConnector(HttpClient, JettyResourceFactory)
Method Summary
All Methods Instance Methods Concrete Methods 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 givenHttpMethodandURIand apply the givenrequestCallbackwhen the HTTP request of the underlying API can be initialized and written to.voidsetBufferFactory(DataBufferFactory bufferFactory)
Constructor Detail
JettyClientHttpConnector
public JettyClientHttpConnector()
Default constructor that creates a new instance ofHttpClient.
JettyClientHttpConnector
public JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient)
Constructor with an initializedHttpClient.
JettyClientHttpConnector
public JettyClientHttpConnector(org.eclipse.jetty.client.HttpClient httpClient, @Nullable JettyResourceFactory resourceFactory)
Constructor with an initializedHttpClientand configures it with the givenJettyResourceFactory.- Parameters:
httpClient- theHttpClientto useresourceFactory- theJettyResourceFactoryto use- Since:
- 5.2
JettyClientHttpConnector
@Deprecated public JettyClientHttpConnector(JettyResourceFactory resourceFactory, @Nullable Consumer<org.eclipse.jetty.client.HttpClient> customizer)
Deprecated.as of 5.2, in favor ofJettyClientHttpConnector(HttpClient, JettyResourceFactory)Constructor with anJettyResourceFactorythat will manage shared resources.- Parameters:
resourceFactory- theJettyResourceFactoryto usecustomizer- the lambda used to customize theHttpClient
Method Detail
setBufferFactory
public void setBufferFactory(DataBufferFactory bufferFactory)
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:ClientHttpConnectorConnect to the origin server using the givenHttpMethodandURIand apply the givenrequestCallbackwhen the HTTP request of the underlying API can be initialized and written to.- Specified by:
connectin interfaceClientHttpConnector- Parameters:
method- the HTTP request methoduri- the HTTP request URIrequestCallback- a function that prepares and writes to the request, returning a publisher that signals when it's done writing. Implementations can return aMono<Void>by callingReactiveHttpOutputMessage.writeWith(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>)orReactiveHttpOutputMessage.setComplete().- Returns:
- publisher for the
ClientHttpResponse