Package org.flowable.http.common.impl.spring.reactive

Class SpringWebClientFlowableHttpClient

java.lang.Object

org.flowable.http.common.impl.spring.reactive.SpringWebClientFlowableHttpClient

All Implemented Interfaces:

FlowableAsyncHttpClient, FlowableHttpClient

public class SpringWebClientFlowableHttpClient
extends Object
implements FlowableAsyncHttpClient

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	SpringWebClientFlowableHttpClient.ByteArrayResourceWithFileName
protected class	SpringWebClientFlowableHttpClient.WebClientExecutableHttpRequest

Field Summary

Fields

Modifier and Type	Field	Description
protected final Duration	initialRequestTimeout
protected final org.slf4j.Logger	logger
protected final WebClient	webClient

Constructor Summary

Constructors

Constructor	Description
SpringWebClientFlowableHttpClient(HttpClientConfig config)
SpringWebClientFlowableHttpClient(WebClient.Builder builder)

Method Summary

Modifier and Type	Method	Description
protected URI	createUri(String url)
protected WebClient	determineWebClient(HttpRequest requestInfo)
AsyncExecutableHttpRequest	prepareRequest(HttpRequest requestInfo)
protected void	setHeaders(WebClient.RequestHeadersSpec<?> base, HttpHeaders headers)
protected void	setRequestEntity(HttpRequest requestInfo, WebClient.RequestBodySpec requestBodySpec)
protected HttpHeaders	toFlowableHeaders(HttpHeaders httpHeaders)
protected HttpResponse	toFlowableHttpResponse(ResponseEntity<ByteArrayResource> response)

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

webClient

protected final WebClient webClient

initialRequestTimeout

protected final Duration initialRequestTimeout

Constructor Details

SpringWebClientFlowableHttpClient

public SpringWebClientFlowableHttpClient(HttpClientConfig config)

SpringWebClientFlowableHttpClient

public SpringWebClientFlowableHttpClient(WebClient.Builder builder)

Method Details

prepareRequest

public AsyncExecutableHttpRequest prepareRequest(HttpRequest requestInfo)

Specified by:

prepareRequest in interface FlowableAsyncHttpClient

Specified by:

prepareRequest in interface FlowableHttpClient

determineWebClient

protected WebClient determineWebClient(HttpRequest requestInfo)

createUri

protected URI createUri(String url)
                 throws URISyntaxException

Throws:

URISyntaxException

setRequestEntity

protected void setRequestEntity(HttpRequest requestInfo,
 WebClient.RequestBodySpec requestBodySpec)

setHeaders

protected void setHeaders(WebClient.RequestHeadersSpec<?> base,
 HttpHeaders headers)

toFlowableHttpResponse

protected HttpResponse toFlowableHttpResponse(ResponseEntity<ByteArrayResource> response)

toFlowableHeaders

protected HttpHeaders toFlowableHeaders(HttpHeaders httpHeaders)