Package org.drasyl.handler.traffic

Class OutboundMessagesThrottlingHandler.RateLimitedQueue

java.lang.Object

org.drasyl.handler.traffic.OutboundMessagesThrottlingHandler.RateLimitedQueue

Enclosing class:

OutboundMessagesThrottlingHandler

public static class OutboundMessagesThrottlingHandler.RateLimitedQueue
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final Queue<Runnable>	queue
final TokenBucket	tokenBucket

Constructor Summary

Constructors

Constructor	Description
RateLimitedQueue(long maxEventsPerSecond)

Method Summary

Modifier and Type	Method	Description
void	add(io.netty.channel.ChannelHandlerContext ctx, Runnable value)
boolean	tryConsume()

Methods inherited from class java.lang.Object

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

Field Details

queue

public final Queue<Runnable> queue

tokenBucket

public final TokenBucket tokenBucket

Constructor Details

RateLimitedQueue

public RateLimitedQueue(long maxEventsPerSecond)

Method Details

add

public void add(io.netty.channel.ChannelHandlerContext ctx,
 Runnable value)

tryConsume

public boolean tryConsume()