Package org.jivesoftware.openfire.nio

Class NettyConnectionHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<String>

org.jivesoftware.openfire.nio.NettyConnectionHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

NettyClientConnectionHandler, NettyComponentConnectionHandler, NettyMultiplexerConnectionHandler, NettyOutboundConnectionHandler, NettyServerConnectionHandler

public abstract class NettyConnectionHandler
extends io.netty.channel.SimpleChannelInboundHandler<String>

A NettyConnectionHandler is responsible for creating new sessions, destroying sessions and delivering received XML stanzas to the proper StanzaHandler.

Subclasses of this will supply a specific StanzaHandler implementation depending on the type of connection to be handled, e.g. C2S, S2S.

Author:

Matthew Vivian, Alex Gidman

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
protected ConnectionConfiguration	configuration	The configuration for new connections.
static io.netty.util.AttributeKey<NettyConnection>	CONNECTION
protected static ThreadLocal<XMPPPacketReader>	PARSER_CACHE
static io.netty.util.AttributeKey<Long>	READ_BYTES
protected boolean	sslInitDone
static io.netty.util.AttributeKey<Long>	WRITTEN_BYTES

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NettyConnectionHandler(ConnectionConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, String message)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
abstract int	getMaxIdleTime()	Returns the max number of seconds a connection can be idle (both ways) before being closed.
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged

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

Field Detail

CONNECTION

public static final io.netty.util.AttributeKey<NettyConnection> CONNECTION

READ_BYTES

public static final io.netty.util.AttributeKey<Long> READ_BYTES

WRITTEN_BYTES

public static final io.netty.util.AttributeKey<Long> WRITTEN_BYTES

PARSER_CACHE

protected static final ThreadLocal<XMPPPacketReader> PARSER_CACHE

sslInitDone

protected boolean sslInitDone

configuration

protected final ConnectionConfiguration configuration

The configuration for new connections.

Constructor Detail

NettyConnectionHandler

protected NettyConnectionHandler(ConnectionConfiguration configuration)

Method Detail

getMaxIdleTime

public abstract int getMaxIdleTime()

Returns the max number of seconds a connection can be idle (both ways) before being closed.

Returns:

the max number of seconds a connection can be idle.

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)

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Overrides:

handlerRemoved in class io.netty.channel.ChannelHandlerAdapter

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                         String message)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<String>

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)

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

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