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

Class ApacheHttpComponentsFlowableHttpClient

java.lang.Object

org.flowable.http.common.impl.apache.ApacheHttpComponentsFlowableHttpClient

All Implemented Interfaces:

org.apache.http.client.HttpClient, FlowableHttpClient

public class ApacheHttpComponentsFlowableHttpClient
extends Object
implements FlowableHttpClient, org.apache.http.client.HttpClient

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ApacheHttpComponentsFlowableHttpClient.ApacheHttpComponentsExecutableHttpRequest
protected static class	ApacheHttpComponentsFlowableHttpClient.HttpDeleteWithBody	A HttpDelete alternative that extends HttpEntityEnclosingRequestBase to allow DELETE with a request body

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.http.impl.client.HttpClientBuilder	clientBuilder
protected int	connectionRequestTimeout
protected int	connectTimeout
protected final org.slf4j.Logger	logger
protected int	socketTimeout

Constructor Summary

Constructors

Constructor	Description
ApacheHttpComponentsFlowableHttpClient(org.apache.http.impl.client.HttpClientBuilder clientBuilder, int socketTimeout, int connectTimeout, int connectionRequestTimeout)
ApacheHttpComponentsFlowableHttpClient(HttpClientConfig config)
ApacheHttpComponentsFlowableHttpClient(HttpClientConfig config, Consumer<org.apache.http.impl.client.HttpClientBuilder> clientBuilderCustomizer)

Method Summary

Modifier and Type	Method	Description
protected URI	createUri(String url)
protected Charset	determineCharset(org.apache.http.client.methods.CloseableHttpResponse response)
org.apache.http.HttpResponse	execute(org.apache.http.client.methods.HttpUriRequest request)
<T> T	execute(org.apache.http.client.methods.HttpUriRequest request, org.apache.http.client.ResponseHandler<? extends T> responseHandler)
<T> T	execute(org.apache.http.client.methods.HttpUriRequest request, org.apache.http.client.ResponseHandler<? extends T> responseHandler, org.apache.http.protocol.HttpContext context)
org.apache.http.HttpResponse	execute(org.apache.http.client.methods.HttpUriRequest request, org.apache.http.protocol.HttpContext context)
org.apache.http.HttpResponse	execute(org.apache.http.HttpHost target, org.apache.http.HttpRequest request)
<T> T	execute(org.apache.http.HttpHost target, org.apache.http.HttpRequest request, org.apache.http.client.ResponseHandler<? extends T> responseHandler)
<T> T	execute(org.apache.http.HttpHost target, org.apache.http.HttpRequest request, org.apache.http.client.ResponseHandler<? extends T> responseHandler, org.apache.http.protocol.HttpContext context)
org.apache.http.HttpResponse	execute(org.apache.http.HttpHost target, org.apache.http.HttpRequest request, org.apache.http.protocol.HttpContext context)
org.apache.http.conn.ClientConnectionManager	getConnectionManager()
protected HttpHeaders	getHeaders(org.apache.http.Header[] headers)
org.apache.http.params.HttpParams	getParams()
ExecutableHttpRequest	prepareRequest(HttpRequest requestInfo)
protected void	setConfig(org.apache.http.client.methods.HttpRequestBase base, HttpRequest requestInfo)
protected void	setHeaders(org.apache.http.HttpMessage base, HttpHeaders headers)
protected void	setRequestEntity(HttpRequest requestInfo, org.apache.http.client.methods.HttpEntityEnclosingRequestBase requestBase)
protected HttpResponse	toFlowableHttpResponse(org.apache.http.client.methods.CloseableHttpResponse 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

clientBuilder

protected org.apache.http.impl.client.HttpClientBuilder clientBuilder

socketTimeout

protected int socketTimeout

connectTimeout

protected int connectTimeout

connectionRequestTimeout

protected int connectionRequestTimeout

Constructor Details

ApacheHttpComponentsFlowableHttpClient

public ApacheHttpComponentsFlowableHttpClient(HttpClientConfig config)

ApacheHttpComponentsFlowableHttpClient

public ApacheHttpComponentsFlowableHttpClient(HttpClientConfig config,
 Consumer<org.apache.http.impl.client.HttpClientBuilder> clientBuilderCustomizer)

ApacheHttpComponentsFlowableHttpClient

public ApacheHttpComponentsFlowableHttpClient(org.apache.http.impl.client.HttpClientBuilder clientBuilder,
 int socketTimeout,
 int connectTimeout,
 int connectionRequestTimeout)

Method Details

prepareRequest

public ExecutableHttpRequest prepareRequest(HttpRequest requestInfo)

Specified by:

prepareRequest in interface FlowableHttpClient

createUri

protected URI createUri(String url)
                 throws URISyntaxException

Throws:

URISyntaxException

setRequestEntity

protected void setRequestEntity(HttpRequest requestInfo,
 org.apache.http.client.methods.HttpEntityEnclosingRequestBase requestBase)
                         throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

setHeaders

protected void setHeaders(org.apache.http.HttpMessage base,
 HttpHeaders headers)

setConfig

protected void setConfig(org.apache.http.client.methods.HttpRequestBase base,
 HttpRequest requestInfo)

toFlowableHttpResponse

protected HttpResponse toFlowableHttpResponse(org.apache.http.client.methods.CloseableHttpResponse response)
                                       throws IOException

Throws:

IOException

determineCharset

protected Charset determineCharset(org.apache.http.client.methods.CloseableHttpResponse response)

getHeaders

protected HttpHeaders getHeaders(org.apache.http.Header[] headers)

getParams

public org.apache.http.params.HttpParams getParams()

Specified by:

getParams in interface org.apache.http.client.HttpClient

getConnectionManager

public org.apache.http.conn.ClientConnectionManager getConnectionManager()

Specified by:

getConnectionManager in interface org.apache.http.client.HttpClient

execute

public org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest request)
                                     throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public org.apache.http.HttpResponse execute(org.apache.http.client.methods.HttpUriRequest request,
 org.apache.http.protocol.HttpContext context)
                                     throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public org.apache.http.HttpResponse execute(org.apache.http.HttpHost target,
 org.apache.http.HttpRequest request)
                                     throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public org.apache.http.HttpResponse execute(org.apache.http.HttpHost target,
 org.apache.http.HttpRequest request,
 org.apache.http.protocol.HttpContext context)
                                     throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public <T> T execute(org.apache.http.client.methods.HttpUriRequest request,
 org.apache.http.client.ResponseHandler<? extends T> responseHandler)
              throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public <T> T execute(org.apache.http.client.methods.HttpUriRequest request,
 org.apache.http.client.ResponseHandler<? extends T> responseHandler,
 org.apache.http.protocol.HttpContext context)
              throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public <T> T execute(org.apache.http.HttpHost target,
 org.apache.http.HttpRequest request,
 org.apache.http.client.ResponseHandler<? extends T> responseHandler)
              throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException

execute

public <T> T execute(org.apache.http.HttpHost target,
 org.apache.http.HttpRequest request,
 org.apache.http.client.ResponseHandler<? extends T> responseHandler,
 org.apache.http.protocol.HttpContext context)
              throws IOException,
org.apache.http.client.ClientProtocolException

Specified by:

execute in interface org.apache.http.client.HttpClient

Throws:

IOException

org.apache.http.client.ClientProtocolException