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

Class DelegatingEventLoopGroup

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

SharedEventLoopGroup

public class DelegatingEventLoopGroup
extends Object
implements io.netty.channel.EventLoopGroup

Constructor Summary

Constructors

Constructor	Description
DelegatingEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
void	forEach(Consumer<? super io.netty.util.concurrent.EventExecutor> action)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isShuttingDown()
boolean	isTerminated()
Iterator<io.netty.util.concurrent.EventExecutor>	iterator()
io.netty.channel.EventLoop	next()
io.netty.channel.ChannelFuture	register(io.netty.channel.Channel channel)
io.netty.channel.ChannelFuture	register(io.netty.channel.ChannelPromise channelPromise)
io.netty.channel.ChannelFuture	register(io.netty.channel.Channel channel, io.netty.channel.ChannelPromise channelPromise)	Deprecated.
io.netty.util.concurrent.ScheduledFuture<?>	schedule(Runnable runnable, long l, TimeUnit timeUnit)
<V> io.netty.util.concurrent.ScheduledFuture<V>	schedule(Callable<V> callable, long l, TimeUnit timeUnit)
io.netty.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(Runnable runnable, long l, long l1, TimeUnit timeUnit)
io.netty.util.concurrent.ScheduledFuture<?>	scheduleWithFixedDelay(Runnable runnable, long l, long l1, TimeUnit timeUnit)
void	shutdown()	Deprecated.
io.netty.util.concurrent.Future<?>	shutdownGracefully()
io.netty.util.concurrent.Future<?>	shutdownGracefully(long l, long l1, TimeUnit timeUnit)
List<Runnable>	shutdownNow()	Deprecated.
Spliterator<io.netty.util.concurrent.EventExecutor>	spliterator()
io.netty.util.concurrent.Future<?>	submit(Runnable runnable)
<T> io.netty.util.concurrent.Future<T>	submit(Runnable runnable, T t)
<T> io.netty.util.concurrent.Future<T>	submit(Callable<T> callable)
io.netty.util.concurrent.Future<?>	terminationFuture()

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingEventLoopGroup

public DelegatingEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)

Method Detail

next

public io.netty.channel.EventLoop next()

Specified by:

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

Specified by:

next in interface io.netty.channel.EventLoopGroup

register

public io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel)

Specified by:

register in interface io.netty.channel.EventLoopGroup

register

public io.netty.channel.ChannelFuture register(io.netty.channel.ChannelPromise channelPromise)

Specified by:

register in interface io.netty.channel.EventLoopGroup

register

@Deprecated
public io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel,
                                               io.netty.channel.ChannelPromise channelPromise)

Deprecated.

Specified by:

register in interface io.netty.channel.EventLoopGroup

isShuttingDown

public boolean isShuttingDown()

Specified by:

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

shutdownGracefully

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

Specified by:

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

shutdownGracefully

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

Specified by:

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

terminationFuture

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

Specified by:

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

shutdown

@Deprecated
public void shutdown()

Deprecated.

Specified by:

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

Specified by:

shutdown in interface ExecutorService

shutdownNow

@Deprecated
public List<Runnable> shutdownNow()

Deprecated.

Specified by:

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

Specified by:

shutdownNow in interface ExecutorService

iterator

public Iterator<io.netty.util.concurrent.EventExecutor> iterator()

Specified by:

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

Specified by:

iterator in interface Iterable<io.netty.util.concurrent.EventExecutor>

submit

public io.netty.util.concurrent.Future<?> submit(Runnable runnable)

Specified by:

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

Specified by:

submit in interface ExecutorService

submit

public <T> io.netty.util.concurrent.Future<T> submit(Runnable runnable,
                                                     T t)

Specified by:

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

Specified by:

submit in interface ExecutorService

submit

public <T> io.netty.util.concurrent.Future<T> submit(Callable<T> callable)

Specified by:

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

Specified by:

submit in interface ExecutorService

schedule

public io.netty.util.concurrent.ScheduledFuture<?> schedule(Runnable runnable,
                                                            long l,
                                                            TimeUnit timeUnit)

Specified by:

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

Specified by:

schedule in interface ScheduledExecutorService

schedule

public <V> io.netty.util.concurrent.ScheduledFuture<V> schedule(Callable<V> callable,
                                                                long l,
                                                                TimeUnit timeUnit)

Specified by:

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

Specified by:

schedule in interface ScheduledExecutorService

scheduleAtFixedRate

public io.netty.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(Runnable runnable,
                                                                       long l,
                                                                       long l1,
                                                                       TimeUnit timeUnit)

Specified by:

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

Specified by:

scheduleAtFixedRate in interface ScheduledExecutorService

scheduleWithFixedDelay

public io.netty.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(Runnable runnable,
                                                                          long l,
                                                                          long l1,
                                                                          TimeUnit timeUnit)

Specified by:

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

Specified by:

scheduleWithFixedDelay in interface ScheduledExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                     long timeout,
                                     TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
                       ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

forEach

public void forEach(Consumer<? super io.netty.util.concurrent.EventExecutor> action)

Specified by:

forEach in interface Iterable<io.netty.util.concurrent.EventExecutor>

spliterator

public Spliterator<io.netty.util.concurrent.EventExecutor> spliterator()

Specified by:

spliterator in interface Iterable<io.netty.util.concurrent.EventExecutor>