Constructor Detail

• AsyncClientEndpoint

  public AsyncClientEndpoint()

Method Detail

• execute

  public abstract void execute(AsyncClientExchangeHandler exchangeHandler,
             HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
             HttpContext context)

  Initiates a message exchange using the given handler.

  Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().

• execute

  public void execute(AsyncClientExchangeHandler exchangeHandler,
             HttpContext context)

  Initiates a message exchange using the given handler.

  Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().

• releaseAndReuse

  public abstract void releaseAndReuse()

  Releases the underlying connection back to the connection pool as re-usable.

• releaseAndDiscard

  public abstract void releaseAndDiscard()

  Shuts down the underlying connection and removes it from the connection pool.

• isConnected

  public abstract boolean isConnected()

  Determines if the connection to the remote endpoint is still open and valid.

• execute

  public final <T> Future<T> execute(AsyncRequestProducer requestProducer,
                      AsyncResponseConsumer<T> responseConsumer,
                      HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
                      HttpContext context,
                      FutureCallback<T> callback)

  Initiates message exchange using the given request producer and response consumer.

  Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().

• execute

  public final <T> Future<T> execute(AsyncRequestProducer requestProducer,
                      AsyncResponseConsumer<T> responseConsumer,
                      HttpContext context,
                      FutureCallback<T> callback)

  Initiates message exchange using the given request producer and response consumer.

  Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().

• execute

  public final <T> Future<T> execute(AsyncRequestProducer requestProducer,
                      AsyncResponseConsumer<T> responseConsumer,
                      FutureCallback<T> callback)

  Initiates a message exchange using the given request producer and response consumer.

  Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().