Module org.apache.qpid.protonj2.client

Package org.apache.qpid.protonj2.client.transport.netty4

Class Netty4IOContext.NettyIOScheduler

java.lang.Object

org.apache.qpid.protonj2.client.transport.netty4.Netty4IOContext.NettyIOScheduler

All Implemented Interfaces:

Executor, org.apache.qpid.protonj2.engine.Scheduler

Enclosing class:

Netty4IOContext

public class Netty4IOContext.NettyIOScheduler
extends Object
implements org.apache.qpid.protonj2.engine.Scheduler, Executor

Constructor Summary

Constructors

Constructor	Description
NettyIOScheduler()

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable command)
boolean	isShutdown()
Future<?>	schedule(Runnable command, long delay, TimeUnit unit)
<V> Future<V>	schedule(Callable<V> task, long delay, TimeUnit unit)
Future<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
Future<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Details

NettyIOScheduler

public NettyIOScheduler()

Method Details

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Specified by:

execute in interface org.apache.qpid.protonj2.engine.Scheduler

schedule

public Future<?> schedule(Runnable command,
 long delay,
 TimeUnit unit)

Specified by:

schedule in interface org.apache.qpid.protonj2.engine.Scheduler

schedule

public <V> Future<V> schedule(Callable<V> task,
 long delay,
 TimeUnit unit)

Specified by:

schedule in interface org.apache.qpid.protonj2.engine.Scheduler

scheduleAtFixedRate

public Future<?> scheduleAtFixedRate(Runnable command,
 long initialDelay,
 long period,
 TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface org.apache.qpid.protonj2.engine.Scheduler

scheduleWithFixedDelay

public Future<?> scheduleWithFixedDelay(Runnable command,
 long initialDelay,
 long delay,
 TimeUnit unit)

Specified by:

scheduleWithFixedDelay in interface org.apache.qpid.protonj2.engine.Scheduler

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface org.apache.qpid.protonj2.engine.Scheduler