org.waarp.openr66.protocol.utils

Class ChannelCloseTimer

java.lang.Object

org.waarp.openr66.protocol.utils.ChannelCloseTimer

All Implemented Interfaces:

io.netty.util.TimerTask

public class ChannelCloseTimer
extends Object
implements io.netty.util.TimerTask

TimerTask to Close a Channel in the future

Constructor Summary

Constructors

Constructor and Description
ChannelCloseTimer(io.netty.channel.Channel channel)
ChannelCloseTimer(io.netty.channel.Channel channel, io.netty.channel.ChannelFuture future)
ChannelCloseTimer(ConnectionActions connectionActions)

Method Summary

Modifier and Type	Method and Description
static void	closeFutureChannel(io.netty.channel.Channel channel) Close in the future this channel
static void	closeFutureChannel(io.netty.channel.Channel channel, io.netty.channel.ChannelFuture future) Close in the future this channel
static void	closeFutureTransaction(ConnectionActions connectionActions) Close in the future this transaction (may need more than 1 WAITFORNETOP)
static void	closeFutureTransaction(ConnectionActions connectionActions, DbSession noconcurrencyDbSession) Close in the future this transaction
void	run(io.netty.util.Timeout timeout)
void	setDbSession(DbSession dbSession)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChannelCloseTimer

public ChannelCloseTimer(io.netty.channel.Channel channel)

ChannelCloseTimer

public ChannelCloseTimer(io.netty.channel.Channel channel,
                         io.netty.channel.ChannelFuture future)

ChannelCloseTimer

public ChannelCloseTimer(ConnectionActions connectionActions)

Method Detail

run

public void run(io.netty.util.Timeout timeout)
         throws Exception

Specified by:

run in interface io.netty.util.TimerTask

Throws:

Exception

closeFutureTransaction

public static void closeFutureTransaction(ConnectionActions connectionActions)

Close in the future this transaction (may need more than 1 WAITFORNETOP)

Parameters:

connectionActions -

closeFutureTransaction

public static void closeFutureTransaction(ConnectionActions connectionActions,
                                          DbSession noconcurrencyDbSession)

Close in the future this transaction

Parameters:

connectionActions -

noconcurrencyDbSession -

setDbSession

public void setDbSession(DbSession dbSession)

closeFutureChannel

public static void closeFutureChannel(io.netty.channel.Channel channel)

Close in the future this channel

Parameters:

channel -

closeFutureChannel

public static void closeFutureChannel(io.netty.channel.Channel channel,
                                      io.netty.channel.ChannelFuture future)

Close in the future this channel

Parameters:

channel -

future - future to wait in addition to other constraints