com.ibasco.agql.core.transport.handlers

Class MessageOutboundHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelOutboundHandlerAdapter

com.ibasco.agql.core.transport.handlers.MessageOutboundHandler

All Implemented Interfaces:

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

public abstract class MessageOutboundHandler
extends io.netty.channel.ChannelOutboundHandlerAdapter

Abstract MessageOutboundHandler 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	MessageOutboundHandler() Constructor for MessageOutboundHandler.
protected	MessageOutboundHandler(Class<? extends AbstractRequest> filterRequestClass, Class<?> filterMessageType) Constructor for MessageOutboundHandler.

Method Summary

Modifier and Type	Method and Description
protected void	debug(String msg, Object... args) debug.
protected void	error(String msg, Object... args) error.
protected NettyChannelContext	getContext() getContext.
protected Envelope<AbstractRequest>	getRequest() getRequest.
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
protected void	info(String msg, Object... args) info.
protected void	log(String msg, BiConsumer<String,Object[]> level, Object... args) log.
protected void	trace(String msg, Object... args) trace.
protected void	warn(String msg, Object... args) warn.
void	write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)
protected void	writeMessage(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) writeMessage.

Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

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

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, exceptionCaught, 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

exceptionCaught

Constructor Detail

MessageOutboundHandler

protected MessageOutboundHandler()

Constructor for MessageOutboundHandler.

MessageOutboundHandler

protected MessageOutboundHandler(Class<? extends AbstractRequest> filterRequestClass,
                                 Class<?> filterMessageType)

Constructor for MessageOutboundHandler.

Parameters:

filterRequestClass - a Class object

filterMessageType - a Class object

Method Detail

writeMessage

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

writeMessage.

Parameters:

ctx - a ChannelHandlerContext object

msg - a Object object

promise - a ChannelPromise object

Throws:

Exception - if any.

write

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

Specified by:

write in interface io.netty.channel.ChannelOutboundHandler

Overrides:

write in class io.netty.channel.ChannelOutboundHandlerAdapter

Throws:

Exception

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

getContext

protected final NettyChannelContext getContext()

getContext.

Returns:

a NettyChannelContext object

getRequest

protected final Envelope<AbstractRequest> getRequest()

getRequest.

Returns:

a Envelope object

trace

protected final 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 final void error(String msg,
                           Object... args)

error.

Parameters:

msg - a String object

args - a Object object

info

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

info.

Parameters:

msg - a String object

args - a Object object

debug

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

debug.

Parameters:

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