org.waarp.commandexec.server

Class LocalExecServerHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<String>

org.waarp.commandexec.server.LocalExecServerHandler

All Implemented Interfaces:

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

Direct Known Subclasses:

LocalExecSslServerHandler

public class LocalExecServerHandler
extends io.netty.channel.SimpleChannelInboundHandler<String>

Handles a server-side channel for LocalExec.

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	answered
protected LocalExecServerInitializer	factory
protected static boolean	isShutdown

Constructor Summary

Constructors

Constructor and Description
LocalExecServerHandler(LocalExecServerInitializer factory, long newdelay) Constructor with a specific delay

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext ctx)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, String msg)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
static boolean	isShutdown(io.netty.channel.Channel channel) Is the Local Exec Server going Shutdown
static void	junitSetNotShutdown()
void	setNewDelay(long newdelay) Change the delay to the specific value.

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

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

factory

protected final LocalExecServerInitializer factory

isShutdown

protected static boolean isShutdown

answered

protected volatile boolean answered

Constructor Detail

LocalExecServerHandler

public LocalExecServerHandler(LocalExecServerInitializer factory,
                              long newdelay)

Constructor with a specific delay

Parameters:

newdelay -

Method Detail

isShutdown

public static boolean isShutdown(io.netty.channel.Channel channel)

Is the Local Exec Server going Shutdown

Parameters:

channel - associated channel

Returns:

True if in Shutdown

junitSetNotShutdown

public static void junitSetNotShutdown()

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

setNewDelay

public void setNewDelay(long newdelay)

Change the delay to the specific value. Need to be called before any receive message.

Parameters:

newdelay -

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                            String msg)
                     throws Exception

Specified by:

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

Throws:

Exception

exceptionCaught

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

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

Throws:

Exception