com.ibasco.agql.core.transport.handlers

Class MessageInboundHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.ibasco.agql.core.transport.handlers.MessageInboundHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

MessageInboundDecoder, SourceQueryDecoder, SourceQuerySplitPacketAssembler

public abstract class MessageInboundHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Abstract MessageInboundHandler class.

Author:

Rafael Luis Ibasco

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MessageInboundHandler() Constructor for MessageInboundHandler.

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected void	debug(org.slf4j.Logger logger, io.netty.channel.ChannelHandlerContext ctx, String msg, Object... args) debug.
protected void	debug(org.slf4j.Logger logger, org.slf4j.Marker marker, String msg, Object... args) debug.
protected void	debug(org.slf4j.Logger logger, String msg, Object... args) debug.
protected void	debug(String msg, Object... args) debug.
protected void	error(org.slf4j.Logger logger, io.netty.channel.ChannelHandlerContext ctx, String msg, Object... args) error.
protected void	error(String msg, Object... args) error.
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
protected void	info(String msg, Object... args) info.
protected boolean	isDebugEnabled() isDebugEnabled.
protected void	log(String msg, BiConsumer<String,Object[]> level, Object... args) log.
protected void	log(String msg, io.netty.channel.ChannelHandlerContext ctx, BiConsumer<String,Object[]> level, Object... args) log.
protected void	printField(String name, Object value) printField.
protected void	readMessage(io.netty.channel.ChannelHandlerContext ctx, Object msg) readMessage.
protected void	trace(String msg, Object... args) trace.
protected void	warn(String msg, Object... args) warn.

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, isSharable

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageInboundHandler

protected MessageInboundHandler()

Constructor for MessageInboundHandler.

Method Detail

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

handlerRemoved

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

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Overrides:

handlerRemoved in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

channelRead

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

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

readMessage

protected void readMessage(io.netty.channel.ChannelHandlerContext ctx,
                           Object msg)
                    throws Exception

readMessage.

Parameters:

ctx - a ChannelHandlerContext object

msg - a Object object

Throws:

Exception - if any.

isDebugEnabled

protected boolean isDebugEnabled()

isDebugEnabled.

Returns:

a boolean

trace

protected void trace(String msg,
                     Object... args)

trace.

Parameters:

msg - a String object

args - a Object object

log

protected final void log(String msg,
                         BiConsumer<String,Object[]> level,
                         Object... args)

log.

Parameters:

msg - a String object

level - a BiConsumer object

args - a Object object

error

protected void error(String msg,
                     Object... args)

error.

Parameters:

msg - a String object

args - a Object object

error

protected void error(org.slf4j.Logger logger,
                     io.netty.channel.ChannelHandlerContext ctx,
                     String msg,
                     Object... args)

error.

Parameters:

logger - a Logger object

ctx - a ChannelHandlerContext object

msg - a String object

args - a Object object

log

protected final void log(String msg,
                         io.netty.channel.ChannelHandlerContext ctx,
                         BiConsumer<String,Object[]> level,
                         Object... args)

log.

Parameters:

msg - a String object

ctx - a ChannelHandlerContext object

level - a BiConsumer object

args - a Object object

info

protected void info(String msg,
                    Object... args)

info.

Parameters:

msg - a String object

args - a Object object

debug

protected void debug(org.slf4j.Logger logger,
                     String msg,
                     Object... args)

debug.

Parameters:

logger - a Logger object

msg - a String object

args - a Object object

debug

protected void debug(org.slf4j.Logger logger,
                     io.netty.channel.ChannelHandlerContext ctx,
                     String msg,
                     Object... args)

debug.

Parameters:

logger - a Logger object

ctx - a ChannelHandlerContext object

msg - a String object

args - a Object object

debug

protected void debug(org.slf4j.Logger logger,
                     org.slf4j.Marker marker,
                     String msg,
                     Object... args)

debug.

Parameters:

logger - a Logger object

marker - a Marker object

msg - a String object

args - a Object object

warn

protected final void warn(String msg,
                          Object... args)

warn.

Parameters:

msg - a String object

args - a Object object

printField

protected void printField(String name,
                          Object value)

printField.

Parameters:

name - a String object

value - a Object object

debug

protected void debug(String msg,
                     Object... args)

debug.

Parameters:

msg - a String object

args - a Object object