Package org.flowable.http.common.impl.apache.client5

Class ApacheHttpComponents5FlowableHttpClient

java.lang.Object

org.flowable.http.common.impl.apache.client5.ApacheHttpComponents5FlowableHttpClient

All Implemented Interfaces:

FlowableAsyncHttpClient, FlowableHttpClient

public class ApacheHttpComponents5FlowableHttpClient
extends Object
implements FlowableAsyncHttpClient

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ApacheHttpComponents5FlowableHttpClient.ApacheHttpComponentsExecutableHttpRequest

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hc.client5.http.async.HttpAsyncClient	client
protected boolean	closeClient
protected int	connectionRequestTimeout
protected int	connectTimeout
protected final org.slf4j.Logger	logger
protected int	socketTimeout

Constructor Summary

Constructors

Constructor	Description
ApacheHttpComponents5FlowableHttpClient(org.apache.hc.client5.http.async.HttpAsyncClient client, int socketTimeout, int connectTimeout, int connectionRequestTimeout)
ApacheHttpComponents5FlowableHttpClient(HttpClientConfig config)
ApacheHttpComponents5FlowableHttpClient(HttpClientConfig config, Consumer<org.apache.hc.client5.http.impl.async.HttpAsyncClientBuilder> clientBuilderCustomizer)

Method Summary

Modifier and Type	Method	Description
void	close()
protected org.apache.hc.client5.http.config.RequestConfig	createRequestConfig(HttpRequest request)
protected URI	createUri(String url)
AsyncExecutableHttpRequest	prepareRequest(HttpRequest requestInfo)
protected void	setHeaders(org.apache.hc.core5.http.nio.support.AsyncRequestBuilder base, HttpHeaders headers)
protected void	setRequestEntity(HttpRequest requestInfo, org.apache.hc.core5.http.nio.support.AsyncRequestBuilder requestBase)
protected HttpResponse	toFlowableHttpResponse(org.apache.hc.client5.http.async.methods.SimpleHttpResponse 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

client

protected org.apache.hc.client5.http.async.HttpAsyncClient client

closeClient

protected boolean closeClient

socketTimeout

protected int socketTimeout

connectTimeout

protected int connectTimeout

connectionRequestTimeout

protected int connectionRequestTimeout

Constructor Details

ApacheHttpComponents5FlowableHttpClient

public ApacheHttpComponents5FlowableHttpClient(HttpClientConfig config)

ApacheHttpComponents5FlowableHttpClient

public ApacheHttpComponents5FlowableHttpClient(HttpClientConfig config,
 Consumer<org.apache.hc.client5.http.impl.async.HttpAsyncClientBuilder> clientBuilderCustomizer)

ApacheHttpComponents5FlowableHttpClient

public ApacheHttpComponents5FlowableHttpClient(org.apache.hc.client5.http.async.HttpAsyncClient client,
 int socketTimeout,
 int connectTimeout,
 int connectionRequestTimeout)

Method Details

close

public void close()

prepareRequest

public AsyncExecutableHttpRequest prepareRequest(HttpRequest requestInfo)

Specified by:

prepareRequest in interface FlowableAsyncHttpClient

Specified by:

prepareRequest in interface FlowableHttpClient

createUri

protected URI createUri(String url)
                 throws URISyntaxException

Throws:

URISyntaxException

setRequestEntity

protected void setRequestEntity(HttpRequest requestInfo,
 org.apache.hc.core5.http.nio.support.AsyncRequestBuilder requestBase)
                         throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

setHeaders

protected void setHeaders(org.apache.hc.core5.http.nio.support.AsyncRequestBuilder base,
 HttpHeaders headers)

createRequestConfig

protected org.apache.hc.client5.http.config.RequestConfig createRequestConfig(HttpRequest request)

toFlowableHttpResponse

protected HttpResponse toFlowableHttpResponse(org.apache.hc.client5.http.async.methods.SimpleHttpResponse response)