org.neo4j.com

Class IdleChannelReaper

java.lang.Object

org.neo4j.com.IdleChannelReaper

All Implemented Interfaces:

Runnable

public class IdleChannelReaper
extends Object
implements Runnable

Keeps track of a set of channels and when they were last active. Run this object periodically to close any channels that have been inactive for longer than the threshold. This functionality is required because sometimes Netty doesn't tell us when channels are closed or disconnected. Most of the time it does, but this acts as a safety net for those we don't get notifications for. When the bug is fixed remove this class.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IdleChannelReaper.Request

Constructor Summary

Constructors

Constructor and Description
IdleChannelReaper(ChannelCloser channelCloser, org.neo4j.logging.LogProvider logProvider, Clock clock, long thresholdMillis)

Method Summary

Modifier and Type	Method and Description
void	add(org.jboss.netty.channel.Channel channel, RequestContext requestContext)
IdleChannelReaper.Request	remove(org.jboss.netty.channel.Channel channel)
void	run()
boolean	update(org.jboss.netty.channel.Channel channel)

Methods inherited from class java.lang.Object

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

Constructor Detail

IdleChannelReaper

public IdleChannelReaper(ChannelCloser channelCloser,
                         org.neo4j.logging.LogProvider logProvider,
                         Clock clock,
                         long thresholdMillis)

Method Detail

add

public void add(org.jboss.netty.channel.Channel channel,
                RequestContext requestContext)

remove

public IdleChannelReaper.Request remove(org.jboss.netty.channel.Channel channel)

update

public boolean update(org.jboss.netty.channel.Channel channel)

run

public void run()

Specified by:

run in interface Runnable