Package io.micronaut.http.server.netty

Class RoutingInBoundHandler

java.lang.Object

io.micronaut.http.server.netty.RoutingInBoundHandler

All Implemented Interfaces:

RequestHandler

@Internal
@Sharable
public final class RoutingInBoundHandler
extends Object
implements RequestHandler

Internal implementation of the ChannelInboundHandler for Micronaut.

Since:

1.0

Author:

Graeme Rocher

Method Summary

Modifier and Type	Method	Description
void	accept(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest request, PipeliningServerHandler.OutboundAccess outboundAccess)	Handle a request.
void	handleUnboundError(Throwable cause)	Handle an error that is not bound to a request, i.e.
void	responseWritten(Object attachment)	Called roughly when a response has been written.
void	writeResponse(PipeliningServerHandler.OutboundAccess outboundAccess, NettyHttpRequest<?> nettyHttpRequest, MutableHttpResponse<?> response, Throwable throwable)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.http.server.netty.handler.RequestHandler

removed

Method Details

responseWritten

public void responseWritten(Object attachment)

Description copied from interface: RequestHandler

Called roughly when a response has been written. In particular, it's called when the user is "done" with the response and has no way of adding further data. The bytes may not have been fully flushed yet, but e.g. the response Publisher has been fully consumed.
This is used for cleaning up the request.

Specified by:

responseWritten in interface RequestHandler

Parameters:

attachment - Object passed to PipeliningServerHandler.OutboundAccess.attachment(Object)

handleUnboundError

public void handleUnboundError(Throwable cause)

Description copied from interface: RequestHandler

Handle an error that is not bound to a request, i.e. happens outside of a StreamedHttpRequest.

Specified by:

handleUnboundError in interface RequestHandler

Parameters:

cause - The error

accept

public void accept(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.handler.codec.http.HttpRequest request,
 PipeliningServerHandler.OutboundAccess outboundAccess)

Description copied from interface: RequestHandler

Handle a request.

Specified by:

accept in interface RequestHandler

Parameters:

ctx - The context this request came in on

request - The request, either a FullHttpRequest or a StreamedHttpRequest

outboundAccess - The PipeliningServerHandler.OutboundAccess to use for writing the response

writeResponse

public void writeResponse(PipeliningServerHandler.OutboundAccess outboundAccess,
 NettyHttpRequest<?> nettyHttpRequest,
 MutableHttpResponse<?> response,
 Throwable throwable)