io.parallec.core.resources

Class HttpClientStore

java.lang.Object

io.parallec.core.resources.HttpClientStore

public class HttpClientStore
extends java.lang.Object

this stores a pair of default embedded fast/slow AsyncHttpClient, and another pair of customized fast/slow AsyncHttpClient. By default the pair of customized ones are just references (duplicates of) the embedded ones. For each Parallel Task, will by default load the Embed-fast client in AsyncHttpClientStore unless you load your specific async http client. You may call setHttpClientTypeCurrentDefault(HttpClientType) to change the default one (default one is the embedded fast)

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncHttpClientFactoryEmbed	httpClientFactoryEmbed The http client factory embed.
private HttpClientType	httpClientTypeCurrentDefault The http client type current default.
private static HttpClientStore	instance The singleton instance.
private java.util.Map<HttpClientType,com.ning.http.client.AsyncHttpClient>	map The Constant map.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	HttpClientStore() Instantiates a new http client store.

Method Summary

Modifier and Type	Method and Description
com.ning.http.client.AsyncHttpClient	getClientByType(HttpClientType type) Gets the client by type.
com.ning.http.client.AsyncHttpClient	getCurrentDefaultClient() Gets the current default client.
com.ning.http.client.AsyncHttpClient	getCustomClientFast() Gets the custom client fast.
com.ning.http.client.AsyncHttpClient	getCustomClientSlow() Gets the custom client slow.
com.ning.http.client.AsyncHttpClient	getEmbedClientFast() default fast is the default.
com.ning.http.client.AsyncHttpClient	getEmbedClientSlow() Gets the embed client slow.
AsyncHttpClientFactoryEmbed	getHttpClientFactoryEmbed() Gets the http client factory embed.
HttpClientType	getHttpClientTypeCurrentDefault() Gets the http client type current default.
static HttpClientStore	getInstance()
java.util.Map<HttpClientType,com.ning.http.client.AsyncHttpClient>	getMap() Gets the map.
void	init() Initialize
void	reinit() close and clean up the http client, then create the new ones.
void	setCustomClientFast(com.ning.http.client.AsyncHttpClient client) Sets the custom client fast.
void	setCustomClientSlow(com.ning.http.client.AsyncHttpClient client) Sets the custom client slow.
void	setHttpClientFactoryEmbed(AsyncHttpClientFactoryEmbed httpClientFactoryEmbed) Sets the http client factory embed.
void	setHttpClientTypeCurrentDefault(HttpClientType httpClientTypeCurrentDefault) this is a key function, and all new command builder will use this one .
void	shutdown() Shutdown each AHC client in the map.

Methods inherited from class java.lang.Object

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

Field Detail

httpClientTypeCurrentDefault

private HttpClientType httpClientTypeCurrentDefault

The http client type current default.

map

private final java.util.Map<HttpClientType,com.ning.http.client.AsyncHttpClient> map

The Constant map.

httpClientFactoryEmbed

private AsyncHttpClientFactoryEmbed httpClientFactoryEmbed

The http client factory embed.

instance

private static final HttpClientStore instance

The singleton instance.

Constructor Detail

HttpClientStore

private HttpClientStore()

Instantiates a new http client store.

Method Detail

getInstance

public static HttpClientStore getInstance()

init

public void init()

Initialize

reinit

public void reinit()

close and clean up the http client, then create the new ones.

shutdown

public void shutdown()

Shutdown each AHC client in the map.

getEmbedClientFast

public com.ning.http.client.AsyncHttpClient getEmbedClientFast()

default fast is the default.

Returns:

the embed client fast

getEmbedClientSlow

public com.ning.http.client.AsyncHttpClient getEmbedClientSlow()

Gets the embed client slow.

Returns:

the embed client slow

getCustomClientFast

public com.ning.http.client.AsyncHttpClient getCustomClientFast()

Gets the custom client fast.

Returns:

the custom client fast

getCustomClientSlow

public com.ning.http.client.AsyncHttpClient getCustomClientSlow()

Gets the custom client slow.

Returns:

the custom client slow

getClientByType

public com.ning.http.client.AsyncHttpClient getClientByType(HttpClientType type)

Gets the client by type.

Parameters:

type - the type

Returns:

the client by type

getCurrentDefaultClient

public com.ning.http.client.AsyncHttpClient getCurrentDefaultClient()

Gets the current default client.

Returns:

the current default client

setCustomClientFast

public void setCustomClientFast(com.ning.http.client.AsyncHttpClient client)

Sets the custom client fast.

Parameters:

client - the new custom client fast

setCustomClientSlow

public void setCustomClientSlow(com.ning.http.client.AsyncHttpClient client)

Sets the custom client slow.

Parameters:

client - the new custom client slow

getHttpClientTypeCurrentDefault

public HttpClientType getHttpClientTypeCurrentDefault()

Gets the http client type current default.

Returns:

the http client type current default

setHttpClientTypeCurrentDefault

public void setHttpClientTypeCurrentDefault(HttpClientType httpClientTypeCurrentDefault)

this is a key function, and all new command builder will use this one .

Parameters:

httpClientTypeCurrentDefault - the new http client type current default

getMap

public java.util.Map<HttpClientType,com.ning.http.client.AsyncHttpClient> getMap()

Gets the map.

Returns:

the map

getHttpClientFactoryEmbed

public AsyncHttpClientFactoryEmbed getHttpClientFactoryEmbed()

Gets the http client factory embed.

Returns:

the http client factory embed

setHttpClientFactoryEmbed

public void setHttpClientFactoryEmbed(AsyncHttpClientFactoryEmbed httpClientFactoryEmbed)

Sets the http client factory embed.

Parameters:

httpClientFactoryEmbed - the new http client factory embed