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	isServer Is this Handler a server side
protected boolean	isSSL Does this Handler is for SSL

Constructor Summary

Constructors

Constructor and Description
NetworkServerHandler(boolean isServer)

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	setKeepAlivedSent()
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

isSSL

protected boolean isSSL

Does this Handler is for SSL

isServer

protected final boolean isServer

Is this Handler a server side

isBlackListed

protected volatile boolean isBlackListed

Is this network connection being refused (black listed)

Constructor Detail

NetworkServerHandler

public NetworkServerHandler(boolean isServer)

Parameters:

isServer -

Method Detail

channelInactive

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

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

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

setKeepAlivedSent

public void setKeepAlivedSent()

channelRead0

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

Specified by:

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

Throws:

Exception

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 DbSession getDbSession()

Returns:

the dbSession

isSsl

public boolean isSsl()

Returns:

True if this Handler is for SSL