public abstract class AsyncConnectionEndpoint
extends java.lang.Object
| Constructor and Description |
|---|
AsyncConnectionEndpoint() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
abstract void |
execute(java.lang.String id,
AsyncClientExchangeHandler exchangeHandler,
<any> pushHandlerFactory,
HttpContext context)
Initiates a message exchange using the given handler.
|
void |
execute(java.lang.String id,
AsyncClientExchangeHandler exchangeHandler,
HttpContext context)
Initiates a message exchange using the given handler.
|
<T> java.util.concurrent.Future<T> |
execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> callback)
Initiates message exchange using the given request producer and response consumer.
|
<T> java.util.concurrent.Future<T> |
execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> pushHandlerFactory,
<any> callback)
Initiates message exchange using the given request producer and response consumer.
|
<T> java.util.concurrent.Future<T> |
execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> pushHandlerFactory,
HttpContext context,
<any> callback)
Initiates message exchange using the given request producer and response consumer.
|
<T> java.util.concurrent.Future<T> |
execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
HttpContext context,
<any> callback)
Initiates message exchange using the given request producer and response consumer.
|
abstract boolean |
isConnected()
Determines if the connection to the remote endpoint is still open and valid.
|
abstract void |
setSocketTimeout(Timeout timeout)
Sets socket timeout.
|
public abstract void execute(java.lang.String id,
AsyncClientExchangeHandler exchangeHandler,
<any> pushHandlerFactory,
HttpContext context)
id - unique operation ID or null.exchangeHandler - the message exchange handler.pushHandlerFactory - the push handler factory.context - the execution context.public abstract boolean isConnected()
public abstract void setSocketTimeout(Timeout timeout)
timeout - the socket timeout.public final void close()
throws java.io.IOException
java.io.IOExceptionpublic void execute(java.lang.String id,
AsyncClientExchangeHandler exchangeHandler,
HttpContext context)
id - unique operation ID or null.exchangeHandler - the message exchange handler.context - the execution context.public final <T> java.util.concurrent.Future<T> execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> pushHandlerFactory,
HttpContext context,
<any> callback)
T - the result representation.id - unique operation ID or null.requestProducer - the request producer.responseConsumer - the response consumer.pushHandlerFactory - the push handler factory.context - the execution context.callback - the result callback.public final <T> java.util.concurrent.Future<T> execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
HttpContext context,
<any> callback)
T - the result representation.id - unique operation ID or null.requestProducer - the request producer.responseConsumer - the response consumer.context - the execution context.callback - the result callback.public final <T> java.util.concurrent.Future<T> execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> pushHandlerFactory,
<any> callback)
T - the result representation.id - unique operation ID or null.requestProducer - the request producer.responseConsumer - the response consumer.pushHandlerFactory - the push handler factory.callback - the result callback.public final <T> java.util.concurrent.Future<T> execute(java.lang.String id,
AsyncRequestProducer requestProducer,
<any> responseConsumer,
<any> callback)
T - the result representation.id - unique operation ID or null.requestProducer - the request producer.responseConsumer - the response consumer.callback - the result callback.