Package org.apache.activemq.artemis.core.remoting.impl.netty

Class SharedEventLoopGroup

java.lang.Object

org.apache.activemq.artemis.core.remoting.impl.netty.DelegatingEventLoopGroup

org.apache.activemq.artemis.core.remoting.impl.netty.SharedEventLoopGroup

All Implemented Interfaces:

io.netty.channel.EventLoopGroup, io.netty.util.concurrent.EventExecutorGroup, Iterable<io.netty.util.concurrent.EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

public class SharedEventLoopGroup
extends DelegatingEventLoopGroup

Method Summary

Modifier and Type	Method	Description
static void	forceShutdown()
static SharedEventLoopGroup	getInstance(Function<ThreadFactory,io.netty.channel.EventLoopGroup> eventLoopGroupSupplier)
io.netty.util.concurrent.Future<?>	shutdownGracefully()
io.netty.util.concurrent.Future<?>	shutdownGracefully(long l, long l2, TimeUnit timeUnit)
io.netty.util.concurrent.Future<?>	terminationFuture()

Methods inherited from class org.apache.activemq.artemis.core.remoting.impl.netty.DelegatingEventLoopGroup

awaitTermination, execute, forEach, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, iterator, next, register, register, register, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownNow, spliterator, submit, submit, submit

Methods inherited from class java.lang.Object

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

Method Detail

forceShutdown

public static void forceShutdown()

getInstance

public static SharedEventLoopGroup getInstance(Function<ThreadFactory,io.netty.channel.EventLoopGroup> eventLoopGroupSupplier)

terminationFuture

public io.netty.util.concurrent.Future<?> terminationFuture()

Specified by:

terminationFuture in interface io.netty.util.concurrent.EventExecutorGroup

Overrides:

terminationFuture in class DelegatingEventLoopGroup

shutdownGracefully

public io.netty.util.concurrent.Future<?> shutdownGracefully()

Specified by:

shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGroup

Overrides:

shutdownGracefully in class DelegatingEventLoopGroup

shutdownGracefully

public io.netty.util.concurrent.Future<?> shutdownGracefully(long l,
                                                             long l2,
                                                             TimeUnit timeUnit)

Specified by:

shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGroup

Overrides:

shutdownGracefully in class DelegatingEventLoopGroup