org.waarp.common.utility

Class WaarpNettyUtil

java.lang.Object

org.waarp.common.utility.WaarpNettyUtil

public final class WaarpNettyUtil
extends Object

Utility class for Netty usage

Method Summary

Modifier and Type	Method and Description
static boolean	awaitIsSuccessOfInterrupted(io.netty.util.concurrent.Future<?> future)
static boolean	awaitOrInterrupted(io.netty.util.concurrent.Future<?> future)
static boolean	awaitOrInterrupted(io.netty.util.concurrent.Future<?> future, long timeMilliseconds)
static void	setBootstrap(io.netty.bootstrap.Bootstrap bootstrap, io.netty.channel.EventLoopGroup group, int timeout) Add default configuration for client bootstrap
static void	setServerBootstrap(io.netty.bootstrap.ServerBootstrap bootstrap, io.netty.channel.EventLoopGroup group, int timeout) Add default configuration for server bootstrap

Methods inherited from class java.lang.Object

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

Method Detail

setBootstrap

public static void setBootstrap(io.netty.bootstrap.Bootstrap bootstrap,
                                io.netty.channel.EventLoopGroup group,
                                int timeout)

Add default configuration for client bootstrap

Parameters:

bootstrap -

group -

timeout -

setServerBootstrap

public static void setServerBootstrap(io.netty.bootstrap.ServerBootstrap bootstrap,
                                      io.netty.channel.EventLoopGroup group,
                                      int timeout)

Add default configuration for server bootstrap

Parameters:

bootstrap -

group -

timeout -

awaitOrInterrupted

public static boolean awaitOrInterrupted(io.netty.util.concurrent.Future<?> future)

Parameters:

future -

Returns:

True if await done, else interruption occurs

awaitOrInterrupted

public static boolean awaitOrInterrupted(io.netty.util.concurrent.Future<?> future,
                                         long timeMilliseconds)

Parameters:

future -

timeMilliseconds -

Returns:

True if await done, else interruption occurs

awaitIsSuccessOfInterrupted

public static boolean awaitIsSuccessOfInterrupted(io.netty.util.concurrent.Future<?> future)

Parameters:

future -

Returns:

True if await and isSuccess, else interruption or not success occurs