public abstract class AbstractServerExchangeHandler<T> extends Object implements AsyncServerExchangeHandler
Constructor and Description |
---|
AbstractServerExchangeHandler() |
Modifier and Type | Method and Description |
---|---|
int |
available()
Returns the number of bytes immediately available for output.
|
void |
consume(ByteBuffer src)
Triggered to pass incoming data to the data consumer.
|
void |
failed(Exception cause)
Triggered to signal a failure in data processing.
|
protected abstract void |
handle(T requestMessage,
AsyncServerRequestHandler.ResponseTrigger responseTrigger,
HttpContext context)
Triggered to handles the request object produced by the
AsyncRequestConsumer returned
from the supplyConsumer(HttpRequest, EntityDetails, HttpContext) method. |
void |
handleRequest(HttpRequest request,
EntityDetails entityDetails,
ResponseChannel responseChannel,
HttpContext context)
Processes the actual HTTP request.
|
void |
produce(DataStreamChannel channel)
Triggered to signal the ability of the underlying data channel
to accept more data.
|
void |
releaseResources() |
void |
streamEnd(List<? extends Header> trailers)
Triggered to signal termination of the data stream.
|
protected abstract AsyncRequestConsumer<T> |
supplyConsumer(HttpRequest request,
EntityDetails entityDetails,
HttpContext context)
Triggered to supply a request consumer to process the incoming request.
|
void |
updateCapacity(CapacityChannel capacityChannel)
Triggered to signal ability of the underlying data stream to receive
data capacity update.
|
protected abstract AsyncRequestConsumer<T> supplyConsumer(HttpRequest request, EntityDetails entityDetails, HttpContext context) throws HttpException
request
- the request message.entityDetails
- the request entity details.context
- the actual execution context.HttpException
protected abstract void handle(T requestMessage, AsyncServerRequestHandler.ResponseTrigger responseTrigger, HttpContext context) throws HttpException, IOException
AsyncRequestConsumer
returned
from the supplyConsumer(HttpRequest, EntityDetails, HttpContext)
method. The handler
can choose to send response messages immediately inside the call or asynchronously
at some later point.requestMessage
- the request message.responseTrigger
- the response trigger.context
- the actual execution context.HttpException
IOException
public final void handleRequest(HttpRequest request, EntityDetails entityDetails, ResponseChannel responseChannel, HttpContext context) throws HttpException, IOException
AsyncServerExchangeHandler
handleRequest
in interface AsyncServerExchangeHandler
request
- the actual request.entityDetails
- the request entity details or null
if the request
does not enclose an entity.responseChannel
- the response channel.context
- the actual execution context.HttpException
IOException
public final void updateCapacity(CapacityChannel capacityChannel) throws IOException
AsyncDataConsumer
updateCapacity
in interface AsyncDataConsumer
capacityChannel
- the channel for capacity updates.IOException
public final void consume(ByteBuffer src) throws IOException
AsyncDataConsumer
consume
in interface AsyncDataConsumer
src
- data source.IOException
public final void streamEnd(List<? extends Header> trailers) throws HttpException, IOException
AsyncDataConsumer
streamEnd
in interface AsyncDataConsumer
trailers
- data stream trailers.HttpException
IOException
public final int available()
AsyncDataProducer
available
in interface AsyncDataProducer
public final void produce(DataStreamChannel channel) throws IOException
AsyncDataProducer
produce
in interface AsyncDataProducer
channel
- the data channel capable to accepting more data.IOException
public final void failed(Exception cause)
AsyncDataExchangeHandler
failed
in interface AsyncDataExchangeHandler
cause
- the cause of the failure.public final void releaseResources()
releaseResources
in interface ResourceHolder
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.