io.vertx.core.net.impl

Class VertxHandler<C extends ConnectionBase>

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

io.vertx.core.net.impl.VertxHandler<C>

All Implemented Interfaces:

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

public final class VertxHandler<C extends ConnectionBase>
extends io.netty.channel.ChannelDuplexHandler

Author:

Norman Maurer

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Method Summary

Modifier and Type	Method and Description
VertxHandler<C>	addHandler(Handler<C> handler) Set an handler to be called when the connection is set on this handler.
void	channelInactive(io.netty.channel.ChannelHandlerContext chctx)
void	channelRead(io.netty.channel.ChannelHandlerContext chctx, Object msg)
void	channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
void	channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx)
void	close(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
static <C extends ConnectionBase> VertxHandler<C>	create(Function<io.netty.channel.ChannelHandlerContext,C> connectionFactory)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext chctx, Throwable t)
C	getConnection()
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
VertxHandler<C>	removeHandler(Handler<C> handler) Set an handler to be called when the connection is unset from this handler.
static io.netty.buffer.ByteBuf	safeBuffer(io.netty.buffer.ByteBuf buf) Copy and release the buf when necessary.
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, connect, deregister, disconnect, flush, read, write

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered

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

Method Detail

create

public static <C extends ConnectionBase> VertxHandler<C> create(Function<io.netty.channel.ChannelHandlerContext,C> connectionFactory)

safeBuffer

public static io.netty.buffer.ByteBuf safeBuffer(io.netty.buffer.ByteBuf buf)

Copy and release the buf when necessary.

This methods assuming the buffer is created by PartialPooledByteBufAllocator and caller has full ownership of the buffer.

The returned buffer will not need to be released and can be wrapped by a Buffer.

Parameters:

buf - the buffer

Returns:

a safe buffer to use

handlerAdded

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

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.channel.ChannelHandlerAdapter

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

addHandler

public VertxHandler<C> addHandler(Handler<C> handler)

Set an handler to be called when the connection is set on this handler.

Parameters:

handler - the handler to be notified

Returns:

this

removeHandler

public VertxHandler<C> removeHandler(Handler<C> handler)

Set an handler to be called when the connection is unset from this handler.

Parameters:

handler - the handler to be notified

Returns:

this

getConnection

public C getConnection()

channelWritabilityChanged

public void channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelWritabilityChanged in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelWritabilityChanged in class io.netty.channel.ChannelInboundHandlerAdapter

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext chctx,
                            Throwable t)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext chctx)

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete

public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelReadComplete in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelReadComplete in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext chctx,
                        Object msg)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

close

public void close(io.netty.channel.ChannelHandlerContext ctx,
                  io.netty.channel.ChannelPromise promise)
           throws Exception

Specified by:

close in interface io.netty.channel.ChannelOutboundHandler

Overrides:

close in class io.netty.channel.ChannelDuplexHandler

Throws:

Exception

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
                               Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Overrides:

userEventTriggered in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception