Package io.kroxylicious.proxy.internal

Class FilterHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.kroxylicious.proxy.internal.FilterHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public class FilterHandler
extends io.netty.channel.ChannelDuplexHandler

A ChannelInboundHandler (for handling requests from downstream) that applies a single Filter.

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
FilterHandler(FilterAndInvoker filterAndInvoker, long timeoutMs, String sniHostname, io.netty.channel.Channel inboundChannel, ClientConnectionStateMachine clientConnectionStateMachine)

Method Summary

Modifier and Type	Method	Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)	Handles inbound requests flowing toward the upstream broker.
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
String	toString()
void	write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)	Handles outbound responses flowing toward the client.

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Constructor Details

FilterHandler

public FilterHandler(FilterAndInvoker filterAndInvoker,
 long timeoutMs,
 @Nullable
 String sniHostname,
 io.netty.channel.Channel inboundChannel,
 ClientConnectionStateMachine clientConnectionStateMachine)

Method Details

toString

public String toString()

Overrides:

toString in class Object

handlerAdded

public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
                  throws Exception

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

write

public void write(io.netty.channel.ChannelHandlerContext ctx,
 Object msg,
 io.netty.channel.ChannelPromise promise)
           throws Exception

Handles outbound responses flowing toward the client. outbound writes are requests that can succeed or fail. The promise allows the original writer to be notified when data reaches the socket (or if an error occurs).

Specified by:

write in interface io.netty.channel.ChannelOutboundHandler

Overrides:

write in class io.netty.channel.ChannelDuplexHandler

Parameters:

ctx - channel handler context for each filter handler

msg - the message being written

promise - the channel promise

Throws:

Exception - if an error occurs

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
 Object msg)
                 throws Exception

Handles inbound requests flowing toward the upstream broker.

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Parameters:

ctx - channel handler context for each filter handler

msg - the message being read

Throws:

Exception - if an error occurs