Module stincmale.server

Package stincmale.server.netty4.tcp.http

Class HttpDispatchMonoHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

stincmale.server.netty4.tcp.DispatchMonoHandler<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse>

stincmale.server.netty4.tcp.http.HttpDispatchMonoHandler

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

@ThreadSafe
@Sharable
public class HttpDispatchMonoHandler
extends DispatchMonoHandler<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse>

DispatchMonoHandler that expects RequestWithMetadata<? extends FullHttpRequest> messages and sends FullHttpResponses downstream.

HttpDispatchMonoHandler handles Connection HTTP header (a.k.a. keep-alive) so that RequestDispatcher SHOULD NOT care about it.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
HttpDispatchMonoHandler(RequestDispatcher<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse> dispatcher, long connectionIdleTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
void	channelRead(ChannelHandlerContext ctx, Object msg)	Uses RequestDispatcher to process the request (msg) and sends response downstream the ChannelPipeline.
protected FullHttpResponse	failureResponse(RequestWithMetadata<? extends FullHttpRequest> request, Throwable failure)	Provides a response to send downstream if processing of the request has failed or some uncaught Throwable was thrown below in the ChannelPipeline.

Methods inherited from class stincmale.server.netty4.tcp.DispatchMonoHandler

channelRegistered, closeChannelAfterResponse, exceptionCaught, fireExceptionOnResponseWriteFailure, getConnectionIdleTimeoutMillis, handlerRemoved, userEventTriggered

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded

Constructor Details

HttpDispatchMonoHandler

public HttpDispatchMonoHandler(RequestDispatcher<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse> dispatcher, long connectionIdleTimeoutMillis)

Parameters:

dispatcher - See DispatchMonoHandler(RequestDispatcher, long).

connectionIdleTimeoutMillis - See DispatchMonoHandler(RequestDispatcher, long).

Method Details

channelRead

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception

Uses RequestDispatcher to process the request (msg) and sends response downstream the ChannelPipeline. If response is null, then writes MonoHandler.VOID_OUTBOUND_MESSAGE, which results in no response being actually sent. Does not propagate msg upstream.

Calls ReferenceCounted.release() on the msg after completion of processing and sending a response if msg is ReferenceCounted.

Wraps msg into RequestWithMetadata if it's not already a RequestWithMetadata.

Specified by:

channelRead in interface ChannelInboundHandler

Overrides:

channelRead in class DispatchMonoHandler<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse>

Throws:

Exception

failureResponse

protected FullHttpResponse failureResponse(@Nullable RequestWithMetadata<? extends FullHttpRequest> request, Throwable failure)

Description copied from class: DispatchMonoHandler

Provides a response to send downstream if processing of the request has failed or some uncaught Throwable was thrown below in the ChannelPipeline. This method is called from DispatchMonoHandler.channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object), DispatchMonoHandler.exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable) if current Channel is active.

Overrides:

failureResponse in class DispatchMonoHandler<RequestWithMetadata<? extends FullHttpRequest>,FullHttpResponse>

Parameters:

request - Provided if available.

failure - A Throwable that was thrown during processing the request,or during sending a response, or during some other operations related to the request or the current Channel.

Returns:

null.