public abstract class AbstractAsyncResponseConsumer<T> extends java.lang.Object implements HttpAsyncResponseConsumer<T>
HttpAsyncResponseConsumer
implementation that relieves its
subclasses from having to manage internal state and provides a number of protected
event methods that they need to implement.Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicBoolean |
completed |
private java.lang.Exception |
ex |
private T |
result |
Constructor and Description |
---|
AbstractAsyncResponseConsumer() |
Modifier and Type | Method and Description |
---|---|
protected abstract T |
buildResult(HttpContext context)
Invoked to generate a result object from the received HTTP response
message.
|
boolean |
cancel() |
void |
close() |
void |
consumeContent(ContentDecoder decoder,
IOControl ioctrl)
Use
onContentReceived(ContentDecoder, IOControl) instead. |
void |
failed(java.lang.Exception ex)
Invoked to signal that the response processing terminated abnormally.
|
protected ContentType |
getContentType(HttpEntity entity) |
java.lang.Exception |
getException()
Returns an exception in case of an abnormal termination.
|
T |
getResult()
Returns a result of the response processing, when available.
|
boolean |
isDone()
Determines whether or not the response processing completed.
|
protected void |
onClose()
Invoked when the consumer is being closed.
|
protected abstract void |
onContentReceived(ContentDecoder decoder,
IOControl ioctrl)
Invoked to process a chunk of content from the
ContentDecoder . |
protected abstract void |
onEntityEnclosed(HttpEntity entity,
ContentType contentType)
Invoked if the response message encloses a content entity.
|
protected abstract void |
onResponseReceived(HttpResponse response)
Invoked when a HTTP response message is received.
|
protected abstract void |
releaseResources()
Invoked to release all system resources currently allocated.
|
void |
responseCompleted(HttpContext context)
Use
buildResult(HttpContext) instead. |
void |
responseReceived(HttpResponse response)
Use
onResponseReceived(HttpResponse) instead. |
private final java.util.concurrent.atomic.AtomicBoolean completed
private volatile T result
private volatile java.lang.Exception ex
protected abstract void onResponseReceived(HttpResponse response) throws HttpException, java.io.IOException
onContentReceived(ContentDecoder, IOControl)
method
will be invoked only if the response messages has a content entity
enclosed.response
- HTTP response message.HttpException
- in case of HTTP protocol violationjava.io.IOException
- in case of an I/O errorprotected abstract void onContentReceived(ContentDecoder decoder, IOControl ioctrl) throws java.io.IOException
ContentDecoder
.
The IOControl
interface can be used to suspend input events
if the consumer is temporarily unable to consume more content.
The consumer can use the ContentDecoder.isCompleted()
method
to find out whether or not the message content has been fully consumed.
decoder
- content decoder.ioctrl
- I/O control of the underlying connection.java.io.IOException
- in case of an I/O errorprotected abstract void onEntityEnclosed(HttpEntity entity, ContentType contentType) throws java.io.IOException
entity
- HTTP entitycontentType
- expected content type.java.io.IOException
- in case of an I/O errorprotected abstract T buildResult(HttpContext context) throws java.lang.Exception
context
- HTTP context.java.lang.Exception
- in case of an abnormal termination.protected abstract void releaseResources()
protected void onClose() throws java.io.IOException
java.io.IOException
- may be thrown by subclasssesprotected ContentType getContentType(HttpEntity entity)
public final void responseReceived(HttpResponse response) throws java.io.IOException, HttpException
onResponseReceived(HttpResponse)
instead.responseReceived
in interface HttpAsyncResponseConsumer<T>
response
- HTTP response message.java.io.IOException
- in case of an I/O errorHttpException
- in case of HTTP protocol violationpublic final void consumeContent(ContentDecoder decoder, IOControl ioctrl) throws java.io.IOException
onContentReceived(ContentDecoder, IOControl)
instead.consumeContent
in interface HttpAsyncResponseConsumer<T>
decoder
- content decoder.ioctrl
- I/O control of the underlying connection.java.io.IOException
- in case of an I/O errorpublic final void responseCompleted(HttpContext context)
buildResult(HttpContext)
instead.responseCompleted
in interface HttpAsyncResponseConsumer<T>
context
- HTTP contextpublic final boolean cancel()
cancel
in interface Cancellable
public final void failed(java.lang.Exception ex)
HttpAsyncResponseConsumer
failed
in interface HttpAsyncResponseConsumer<T>
ex
- exceptionpublic final void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public java.lang.Exception getException()
HttpAsyncResponseConsumer
null
if the response processing is still ongoing
or if it completed successfully.getException
in interface HttpAsyncResponseConsumer<T>
HttpAsyncResponseConsumer.isDone()
public T getResult()
HttpAsyncResponseConsumer
null
if the response processing is still ongoing.getResult
in interface HttpAsyncResponseConsumer<T>
HttpAsyncResponseConsumer.isDone()
public boolean isDone()
HttpAsyncResponseConsumer
HttpAsyncResponseConsumer.getResult()
can be used to obtain the result. If the response processing terminated
abnormally HttpAsyncResponseConsumer.getException()
can be used to obtain the cause.isDone
in interface HttpAsyncResponseConsumer<T>