org.thales.punch.netty.impl

Class NettyLumberjackPeerContext

java.lang.Object

org.thales.punch.netty.impl.NettyLumberjackPeerContext

All Implemented Interfaces:

Runnable

public class NettyLumberjackPeerContext
extends Object
implements Runnable

Each lumberjack peer is associated to an instance of this class.

It is used to slow down the peer socket reading should we have too much data in the send queue.

It is also used for keep alive sending/receiving.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
protected void	receivedKeepAliveAck()
protected void	refreshKeepAlive()
void	run()
protected void	setFuture(io.netty.util.concurrent.ScheduledFuture<?> future)

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

setFuture

protected void setFuture(io.netty.util.concurrent.ScheduledFuture<?> future)

refreshKeepAlive

protected void refreshKeepAlive()

receivedKeepAliveAck

protected void receivedKeepAliveAck()