com.ning.http.client.providers.netty
Class NettyAsyncHttpProvider
java.lang.Object
org.jboss.netty.channel.SimpleChannelUpstreamHandler
com.ning.http.client.providers.netty.NettyAsyncHttpProvider
- All Implemented Interfaces:
- AsyncHttpProvider, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler
public class NettyAsyncHttpProvider
- extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
- implements AsyncHttpProvider
Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler |
org.jboss.netty.channel.ChannelHandler.Sharable |
Method Summary |
protected static boolean |
abortOnConnectCloseException(Throwable cause)
|
protected static boolean |
abortOnDisconnectException(Throwable cause)
|
protected static boolean |
abortOnReadCloseException(Throwable cause)
|
protected static boolean |
abortOnWriteCloseException(Throwable cause)
|
protected static org.jboss.netty.handler.codec.http.HttpRequest |
buildRequest(AsyncHttpClientConfig config,
Request request,
URI uri,
boolean allowConnect,
org.jboss.netty.buffer.ChannelBuffer buffer)
|
void |
channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelStateEvent e)
|
void |
close()
Close the current underlying TCP/HTTP connection. |
void |
exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e)
|
|
execute(Request request,
AsyncHandler<T> asyncHandler)
Execute the request and invoke the AsyncHandler when the response arrive. |
protected AsyncHttpClientConfig |
getConfig()
|
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e)
|
static
|
newFuture(URI uri,
Request request,
AsyncHandler<T> asyncHandler,
org.jboss.netty.handler.codec.http.HttpRequest nettyRequest,
AsyncHttpClientConfig config,
NettyAsyncHttpProvider provider)
|
Response |
prepareResponse(HttpResponseStatus status,
HttpResponseHeaders headers,
Collection<HttpResponseBodyPart> bodyParts)
Prepare a Response |
protected boolean |
remotelyClosed(org.jboss.netty.channel.Channel channel,
NettyResponseFuture<?> future)
|
protected static int |
requestTimeout(AsyncHttpClientConfig config,
PerRequestConfig perRequestConfig)
|
String |
toString()
|
protected
|
writeRequest(org.jboss.netty.channel.Channel channel,
AsyncHttpClientConfig config,
NettyResponseFuture<T> future,
org.jboss.netty.handler.codec.http.HttpRequest nettyRequest)
|
Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler |
channelBound, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream, writeComplete |
IN_IO_THREAD
public static final ThreadLocal<Boolean> IN_IO_THREAD
NettyAsyncHttpProvider
public NettyAsyncHttpProvider(AsyncHttpClientConfig config)
toString
public String toString()
- Overrides:
toString
in class Object
writeRequest
protected final <T> void writeRequest(org.jboss.netty.channel.Channel channel,
AsyncHttpClientConfig config,
NettyResponseFuture<T> future,
org.jboss.netty.handler.codec.http.HttpRequest nettyRequest)
buildRequest
protected static final org.jboss.netty.handler.codec.http.HttpRequest buildRequest(AsyncHttpClientConfig config,
Request request,
URI uri,
boolean allowConnect,
org.jboss.netty.buffer.ChannelBuffer buffer)
throws IOException
- Throws:
IOException
close
public void close()
- Description copied from interface:
AsyncHttpProvider
- Close the current underlying TCP/HTTP connection.
- Specified by:
close
in interface AsyncHttpProvider
prepareResponse
public Response prepareResponse(HttpResponseStatus status,
HttpResponseHeaders headers,
Collection<HttpResponseBodyPart> bodyParts)
- Description copied from interface:
AsyncHttpProvider
- Prepare a
Response
- Specified by:
prepareResponse
in interface AsyncHttpProvider
- Parameters:
status
- HttpResponseStatus
headers
- HttpResponseHeaders
bodyParts
- list of HttpResponseBodyPart
- Returns:
- a
Response
execute
public <T> ListenableFuture<T> execute(Request request,
AsyncHandler<T> asyncHandler)
throws IOException
- Description copied from interface:
AsyncHttpProvider
- Execute the request and invoke the
AsyncHandler
when the response arrive.
- Specified by:
execute
in interface AsyncHttpProvider
asyncHandler
- an instance of AsyncHandler
- Returns:
- a
ListenableFuture
of Type T.
- Throws:
IOException
requestTimeout
protected static int requestTimeout(AsyncHttpClientConfig config,
PerRequestConfig perRequestConfig)
messageReceived
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e)
throws Exception
- Overrides:
messageReceived
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
- Throws:
Exception
channelClosed
public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelStateEvent e)
throws Exception
- Overrides:
channelClosed
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
- Throws:
Exception
remotelyClosed
protected boolean remotelyClosed(org.jboss.netty.channel.Channel channel,
NettyResponseFuture<?> future)
exceptionCaught
public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e)
throws Exception
- Overrides:
exceptionCaught
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
- Throws:
Exception
abortOnConnectCloseException
protected static boolean abortOnConnectCloseException(Throwable cause)
abortOnDisconnectException
protected static boolean abortOnDisconnectException(Throwable cause)
abortOnReadCloseException
protected static boolean abortOnReadCloseException(Throwable cause)
abortOnWriteCloseException
protected static boolean abortOnWriteCloseException(Throwable cause)
newFuture
public static <T> NettyResponseFuture<T> newFuture(URI uri,
Request request,
AsyncHandler<T> asyncHandler,
org.jboss.netty.handler.codec.http.HttpRequest nettyRequest,
AsyncHttpClientConfig config,
NettyAsyncHttpProvider provider)
getConfig
protected AsyncHttpClientConfig getConfig()
Copyright © 2011. All Rights Reserved.