Package com.linkedin.alpini.router.impl.netty4

Class TimerTimeoutProcessor

java.lang.Object

com.linkedin.alpini.router.impl.netty4.TimerTimeoutProcessor

All Implemented Interfaces:

RouterTimeoutProcessor, java.util.concurrent.Executor

public class TimerTimeoutProcessor
extends java.lang.Object
implements RouterTimeoutProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface com.linkedin.alpini.router.api.RouterTimeoutProcessor

RouterTimeoutProcessor.TimeoutFuture

Constructor Summary

Constructors

Constructor	Description
TimerTimeoutProcessor(io.netty.util.Timer timer)

Method Summary

Modifier and Type	Method	Description
void	execute(java.lang.Runnable command)
RouterTimeoutProcessor.TimeoutFuture	schedule(java.lang.Runnable task, long scheduleDelay, java.util.concurrent.TimeUnit unit)
<T> T	unwrap(java.lang.Class<T> clazz)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerTimeoutProcessor

public TimerTimeoutProcessor(@Nonnull
                             io.netty.util.Timer timer)

Method Detail

schedule

@Nonnull
public RouterTimeoutProcessor.TimeoutFuture schedule(@Nonnull
                                                     java.lang.Runnable task,
                                                     @Nonnegative
                                                     long scheduleDelay,
                                                     @Nonnull
                                                     java.util.concurrent.TimeUnit unit)

Specified by:

schedule in interface RouterTimeoutProcessor

unwrap

@Nonnull
public <T> T unwrap(@Nonnull
                    java.lang.Class<T> clazz)

Specified by:

unwrap in interface RouterTimeoutProcessor

execute

public void execute(@Nonnull
                    java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor