public class RateLimitedConnection extends ClientConnection
ClientConnection.QueuedPacket
Modifier and Type | Field and Description |
---|---|
private static Logger |
LOGGER |
private static Text |
RATE_LIMIT_EXCEEDED_MESSAGE |
private int |
rateLimit |
ATTR_KEY_PROTOCOL, CLIENT_IO_GROUP, CLIENT_IO_GROUP_EPOLL, CLIENT_IO_GROUP_LOCAL, MARKER_NETWORK, MARKER_NETWORK_PACKETS
Constructor and Description |
---|
RateLimitedConnection(int rateLimit) |
Modifier and Type | Method and Description |
---|---|
protected void |
updateStats() |
channelActive, channelInactive, channelRead0, connect, connectLocal, disableAutoRead, disconnect, exceptionCaught, getAddress, getAveragePacketsReceived, getAveragePacketsSent, getDisconnectReason, getPacketListener, handleDisconnection, hasChannel, isEncrypted, isLocal, isOpen, send, send, setCompressionThreshold, setPacketListener, setState, setupEncryption, tick
acceptInboundMessage, channelRead
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
private static final Logger LOGGER
private static final Text RATE_LIMIT_EXCEEDED_MESSAGE
private final int rateLimit
protected void updateStats()
updateStats
in class ClientConnection