org.mule.module.http.internal.request.grizzly

Class GrizzlyHttpClient

java.lang.Object

org.mule.module.http.internal.request.grizzly.GrizzlyHttpClient

All Implemented Interfaces:

Startable, Stoppable, HttpClient

public class GrizzlyHttpClient
extends Object
implements HttpClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	GrizzlyHttpClient.RequestConfigurer

Field Summary

Fields

Modifier and Type	Field and Description
static String	AVOID_ZERO_CONTENT_LENGTH
static String	CUSTOM_MAX_HTTP_PACKET_HEADER_SIZE
static String	HOST_SEPARATOR

Fields inherited from interface org.mule.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Stoppable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
GrizzlyHttpClient(HttpClientConfiguration config)

Method Summary

Modifier and Type	Method and Description
protected com.ning.http.client.ProxyServer	buildProxy(ProxyConfig proxyConfig)
protected HttpResponse	createMuleResponse(com.ning.http.client.Response response, InputStream inputStream)
protected com.ning.http.client.RequestBuilder	createRequestBuilder(HttpRequest request, GrizzlyHttpClient.RequestConfigurer requestConfigurer)
protected void	doConfigureProxy(com.ning.http.client.AsyncHttpClientConfig.Builder builder, ProxyConfig proxyConfig)
protected ProxyConfig	getProxyConfig()
protected void	populateHeaders(HttpRequest request, com.ning.http.client.RequestBuilder builder)
HttpResponse	send(HttpRequest request, int responseTimeout, boolean followRedirects, HttpRequestAuthentication authentication) Sends a HttpRequest blocking the current thread until a response is available for the request times out.
void	send(HttpRequest request, int responseTimeout, boolean followRedirects, HttpRequestAuthentication authentication, CompletionHandler<HttpResponse,Exception> completionHandler, WorkManager workManager) Sends a HttpRequest without blocking the current thread.
HttpResponse	sendAndDefer(HttpRequest request, int responseTimeout, boolean followRedirects, HttpRequestAuthentication authentication) Blocking send which uses a PipedOutputStream to populate the HTTP response as it arrives and propagates a PipedInputStream as soon as the response headers are parsed.
InputStream	sendAndReceiveInputStream(HttpRequest request, int responseTimeout, boolean followRedirects, HttpRequestAuthentication authentication) Sends a HttpRequest blocking the current thread until a response is available for the request times out.
HttpResponse	sendAndWait(HttpRequest request, int responseTimeout, boolean followRedirects, HttpRequestAuthentication authentication) Blocking send which waits to load the whole response to memory before propagating it.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

CUSTOM_MAX_HTTP_PACKET_HEADER_SIZE

public static final String CUSTOM_MAX_HTTP_PACKET_HEADER_SIZE

See Also:

Constant Field Values

AVOID_ZERO_CONTENT_LENGTH

public static final String AVOID_ZERO_CONTENT_LENGTH

See Also:

Constant Field Values

HOST_SEPARATOR

public static final String HOST_SEPARATOR

See Also:

Constant Field Values

Constructor Detail

GrizzlyHttpClient

public GrizzlyHttpClient(HttpClientConfiguration config)

Method Detail

start

public void start()
           throws MuleException

Specified by:

start in interface Startable

Throws:

MuleException

doConfigureProxy

protected void doConfigureProxy(com.ning.http.client.AsyncHttpClientConfig.Builder builder,
                                ProxyConfig proxyConfig)

buildProxy

protected final com.ning.http.client.ProxyServer buildProxy(ProxyConfig proxyConfig)

send

public HttpResponse send(HttpRequest request,
                         int responseTimeout,
                         boolean followRedirects,
                         HttpRequestAuthentication authentication)
                  throws IOException,
                         TimeoutException

Description copied from interface: HttpClient

Sends a HttpRequest blocking the current thread until a response is available for the request times out.

Specified by:

send in interface HttpClient

Throws:

IOException

TimeoutException

sendAndDefer

public HttpResponse sendAndDefer(HttpRequest request,
                                 int responseTimeout,
                                 boolean followRedirects,
                                 HttpRequestAuthentication authentication)
                          throws IOException,
                                 TimeoutException

Blocking send which uses a PipedOutputStream to populate the HTTP response as it arrives and propagates a PipedInputStream as soon as the response headers are parsed.

Because of the internal buffer used to hold the arriving chunks, the response MUST be eventually read or the worker threads will block waiting to allocate them. Likewise, read/write speed differences could cause issues. The buffer size can be customized for these reason.

Throws:

IOException

TimeoutException

sendAndWait

public HttpResponse sendAndWait(HttpRequest request,
                                int responseTimeout,
                                boolean followRedirects,
                                HttpRequestAuthentication authentication)
                         throws IOException,
                                TimeoutException

Blocking send which waits to load the whole response to memory before propagating it.

Throws:

IOException

TimeoutException

send

public void send(HttpRequest request,
                 int responseTimeout,
                 boolean followRedirects,
                 HttpRequestAuthentication authentication,
                 CompletionHandler<HttpResponse,Exception> completionHandler,
                 WorkManager workManager)

Description copied from interface: HttpClient

Sends a HttpRequest without blocking the current thread. When a response is available or the request times out the provided CompletionHandler will be invoked.

Specified by:

send in interface HttpClient

createMuleResponse

protected HttpResponse createMuleResponse(com.ning.http.client.Response response,
                                          InputStream inputStream)
                                   throws IOException

Throws:

IOException

createRequestBuilder

protected com.ning.http.client.RequestBuilder createRequestBuilder(HttpRequest request,
                                                                   GrizzlyHttpClient.RequestConfigurer requestConfigurer)
                                                            throws IOException

Throws:

IOException

populateHeaders

protected void populateHeaders(HttpRequest request,
                               com.ning.http.client.RequestBuilder builder)

getProxyConfig

protected ProxyConfig getProxyConfig()

stop

public void stop()

Specified by:

stop in interface Stoppable

sendAndReceiveInputStream

public InputStream sendAndReceiveInputStream(HttpRequest request,
                                             int responseTimeout,
                                             boolean followRedirects,
                                             HttpRequestAuthentication authentication)
                                      throws IOException,
                                             TimeoutException

Description copied from interface: HttpClient

Sends a HttpRequest blocking the current thread until a response is available for the request times out.

Specified by:

sendAndReceiveInputStream in interface HttpClient

Throws:

IOException

TimeoutException