Field Detail

• MAX_RETRY

  public static final String MAX_RETRY

  See Also:

  Constant Field Values

Constructor Detail

• NettyResponseFuture

  public NettyResponseFuture(URI uri,
                     Request request,
                     AsyncHandler<V> asyncHandler,
                     org.jboss.netty.handler.codec.http.HttpRequest nettyRequest,
                     int responseTimeoutInMs,
                     NettyAsyncHttpProvider asyncHttpProvider)

Method Detail

• getURI

  protected URI getURI()
                throws MalformedURLException

  Throws:

  MalformedURLException

• setURI

  protected void setURI(URI uri)

• isDone

  public boolean isDone()

• isCancelled

  public boolean isCancelled()

• cancel

  public boolean cancel(boolean force)

• hasExpired

  public boolean hasExpired()

  Is the Future still valid

  Returns:

  true if response has expired and should be terminated.

• get

  public V get()
        throws InterruptedException,
               ExecutionException

  Throws:

  InterruptedException

  ExecutionException

• get

  public V get(long l,
      TimeUnit tu)
        throws InterruptedException,
               TimeoutException,
               ExecutionException

  Throws:

  InterruptedException

  TimeoutException

  ExecutionException

• done

  public final void done(Callable callable)

  Description copied from interface: ListenableFuture
  Execute a Callable and if there is no exception, mark this Future as done and release the internal lock.

• abort

  public final void abort(Throwable t)

  Description copied from interface: ListenableFuture
  Abort the current processing, and propagate the Throwable to the AsyncHandler or Future

• content

  public void content(V v)

  Description copied from interface: ListenableFuture
  Set the content that will be returned by this instance

  Parameters:

  v - the content that will be returned by this instance

• getRequest

  protected final Request getRequest()

• getNettyRequest

  public final org.jboss.netty.handler.codec.http.HttpRequest getNettyRequest()

• setNettyRequest

  protected final void setNettyRequest(org.jboss.netty.handler.codec.http.HttpRequest nettyRequest)

• getAsyncHandler

  protected final AsyncHandler<V> getAsyncHandler()

• getKeepAlive

  protected final boolean getKeepAlive()

• setKeepAlive

  protected final void setKeepAlive(boolean keepAlive)

• getHttpResponse

  protected final org.jboss.netty.handler.codec.http.HttpResponse getHttpResponse()

• setHttpResponse

  protected final void setHttpResponse(org.jboss.netty.handler.codec.http.HttpResponse httpResponse)

• incrementAndGetCurrentRedirectCount

  protected int incrementAndGetCurrentRedirectCount()

• setReaperFuture

  protected void setReaperFuture(Future<?> reaperFuture)

• isInAuth

  protected boolean isInAuth()

• getAndSetAuth

  protected boolean getAndSetAuth(boolean inDigestAuth)

• getState

  protected com.ning.http.client.providers.netty.NettyResponseFuture.STATE getState()

• setState

  protected void setState(com.ning.http.client.providers.netty.NettyResponseFuture.STATE state)

• getAndSetStatusReceived

  public boolean getAndSetStatusReceived(boolean sr)

• touch

  public void touch()

  Touch the current instance to prevent external service to times out.

• getAndSetWriteHeaders

  public boolean getAndSetWriteHeaders(boolean writeHeaders)

  Write the Request headers

• getAndSetWriteBody

  public boolean getAndSetWriteBody(boolean writeBody)

  Write the Request body

• provider

  protected NettyAsyncHttpProvider provider()

• attachChannel

  protected void attachChannel(org.jboss.netty.channel.Channel channel)

• attachChannel

  protected void attachChannel(org.jboss.netty.channel.Channel channel,
                   boolean reuseChannel)

• channel

  protected org.jboss.netty.channel.Channel channel()

• reuseChannel

  protected boolean reuseChannel()

• canRetry

  protected boolean canRetry()

• setRequest

  public void setRequest(Request request)

• cannotBeReplay

  public boolean cannotBeReplay()

  Return true if the Future cannot be recovered. There is some scenario where a connection can be closed by an unexpected IOException, and in some situation we can recover from that exception.

  Returns:

  true if that Future cannot be recovered.

• toString

  public String toString()

  Overrides:

  toString in class Object