org.elasticsearch.common.netty
Class OpenChannelsHandler

java.lang.Object
  org.elasticsearch.common.netty.OpenChannelsHandler

All Implemented Interfaces:

org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

@ChannelHandler.Sharable
public class OpenChannelsHandler
extends Object
implements org.jboss.netty.channel.ChannelUpstreamHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

OpenChannelsHandler(ESLogger logger)

Method Summary

void	close()
void	handleUpstream(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelEvent e)
long	numberOfOpenChannels()
long	totalChannels()

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenChannelsHandler

public OpenChannelsHandler(ESLogger logger)

Method Detail

handleUpstream

public void handleUpstream(org.jboss.netty.channel.ChannelHandlerContext ctx,
                           org.jboss.netty.channel.ChannelEvent e)
                    throws Exception

Specified by:

handleUpstream in interface org.jboss.netty.channel.ChannelUpstreamHandler

Throws:

Exception

numberOfOpenChannels

public long numberOfOpenChannels()

totalChannels

public long totalChannels()

close

public void close()