Package org.apache.http.nio.protocol
Class BasicAsyncRequestConsumer
java.lang.Object
org.apache.http.nio.protocol.AbstractAsyncRequestConsumer<HttpRequest>
org.apache.http.nio.protocol.BasicAsyncRequestConsumer
- All Implemented Interfaces:
Closeable
,AutoCloseable
,HttpAsyncRequestConsumer<HttpRequest>
Basic implementation of
HttpAsyncRequestConsumer
. Please note that
this consumer buffers request content in memory and should be used for
relatively small request messages.- Since:
- 4.2
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate SimpleInputBuffer
private static final int
private HttpRequest
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected HttpRequest
buildResult
(HttpContext context) Invoked to generate a result object from the received HTTP request message.protected void
onContentReceived
(ContentDecoder decoder, IOControl ioControl) Invoked to process a chunk of content from theContentDecoder
.protected void
onEntityEnclosed
(HttpEntity entity, ContentType contentType) Invoked if the request message encloses a content entity.protected void
onRequestReceived
(HttpRequest request) Invoked when a HTTP request message is received.protected void
Invoked to release all system resources currently allocated.Methods inherited from class org.apache.http.nio.protocol.AbstractAsyncRequestConsumer
close, consumeContent, failed, getException, getResult, isDone, onClose, requestCompleted, requestReceived
-
Field Details
-
MAX_INITIAL_BUFFER_SIZE
private static final int MAX_INITIAL_BUFFER_SIZE- See Also:
-
request
-
buf
-
-
Constructor Details
-
BasicAsyncRequestConsumer
public BasicAsyncRequestConsumer()
-
-
Method Details
-
onRequestReceived
Description copied from class:AbstractAsyncRequestConsumer
Invoked when a HTTP request message is received. Please note that theAbstractAsyncRequestConsumer.onContentReceived(ContentDecoder, IOControl)
method will be invoked only for if the request message implementsHttpEntityEnclosingRequest
interface and has a content entity enclosed.- Specified by:
onRequestReceived
in classAbstractAsyncRequestConsumer<HttpRequest>
- Parameters:
request
- HTTP request message.- Throws:
IOException
- in case of an I/O error
-
onEntityEnclosed
Description copied from class:AbstractAsyncRequestConsumer
Invoked if the request message encloses a content entity.- Specified by:
onEntityEnclosed
in classAbstractAsyncRequestConsumer<HttpRequest>
- Parameters:
entity
- HTTP entitycontentType
- expected content type.- Throws:
IOException
- in case of an I/O error
-
onContentReceived
Description copied from class:AbstractAsyncRequestConsumer
Invoked to process a chunk of content from theContentDecoder
. TheIOControl
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.- Specified by:
onContentReceived
in classAbstractAsyncRequestConsumer<HttpRequest>
- Parameters:
decoder
- content decoder.ioControl
- I/O control of the underlying connection.- Throws:
IOException
- in case of an I/O error
-
releaseResources
protected void releaseResources()Description copied from class:AbstractAsyncRequestConsumer
Invoked to release all system resources currently allocated.- Specified by:
releaseResources
in classAbstractAsyncRequestConsumer<HttpRequest>
-
buildResult
Description copied from class:AbstractAsyncRequestConsumer
Invoked to generate a result object from the received HTTP request message.- Specified by:
buildResult
in classAbstractAsyncRequestConsumer<HttpRequest>
- Parameters:
context
- HTTP context.- Returns:
- result of the request processing.
-