Field Detail

• IN_IO_THREAD

  public static final ThreadLocal<Boolean> IN_IO_THREAD

Constructor Detail

• NettyAsyncHttpProvider

  public NettyAsyncHttpProvider(AsyncHttpClientConfig config)

Method Detail

• 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()