org.waarp.openr66.protocol.networkhandler

Class NetworkServerHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<NetworkPacket>

org.waarp.openr66.protocol.networkhandler.NetworkServerHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

NetworkSslServerHandler

public class NetworkServerHandler
extends io.netty.channel.SimpleChannelInboundHandler<NetworkPacket>

Network Server Handler (Requester side)

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 and Description
protected boolean	isBlackListed Is this network connection being refused (black listed)
protected boolean	isShuttingDown Is this network connection being refused (shutting down)
protected boolean	isSSL Does this Handler is for SSL
static io.netty.util.AttributeKey<R66Auth>	REUSABLE_AUTH_KEY
static String	REUSABLE_AUTH_KEY_NAME

Constructor Summary

Constructors

Constructor and Description
NetworkServerHandler()

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, NetworkPacket msg)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
DbSession	getDbSession()
boolean	isSsl()
void	resetKeepAlive()
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
static void	writeError(io.netty.channel.Channel channel, Integer remoteId, Integer localId, AbstractLocalPacket error) Write error back to remote client

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, 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

handlerAdded, handlerRemoved

Field Detail

REUSABLE_AUTH_KEY_NAME

public static final String REUSABLE_AUTH_KEY_NAME

See Also:

Constant Field Values

REUSABLE_AUTH_KEY

public static final io.netty.util.AttributeKey<R66Auth> REUSABLE_AUTH_KEY

isSSL

protected boolean isSSL

Does this Handler is for SSL

isBlackListed

protected boolean isBlackListed

Is this network connection being refused (black listed)

isShuttingDown

protected boolean isShuttingDown

Is this network connection being refused (shutting down)

Constructor Detail

NetworkServerHandler

public NetworkServerHandler()

Method Detail

channelInactive

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

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

channelActive

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

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

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

resetKeepAlive

public final void resetKeepAlive()

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                         NetworkPacket msg)

Specified by:

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

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

writeError

public static void writeError(io.netty.channel.Channel channel,
                              Integer remoteId,
                              Integer localId,
                              AbstractLocalPacket error)

Write error back to remote client

Parameters:

channel -

remoteId -

localId -

error -

getDbSession

public final DbSession getDbSession()

Returns:

the dbSession

isSsl

public final boolean isSsl()

Returns:

True if this Handler is for SSL