org.xbib.elasticsearch.common.netty

Class OpenChannelsHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.xbib.elasticsearch.common.netty.OpenChannelsHandler

All Implemented Interfaces:

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

@ChannelHandler.Sharable
public class OpenChannelsHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler

Nested Class Summary

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

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
OpenChannelsHandler(org.elasticsearch.common.logging.ESLogger logger)

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.netty.channel.Channel	channel(Integer id)
void	close()
void	handleUpstream(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelEvent e)
long	numberOfOpenChannels()
long	totalChannels()

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, exceptionCaught, messageReceived, writeComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenChannelsHandler

public OpenChannelsHandler(org.elasticsearch.common.logging.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

Overrides:

handleUpstream in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

Throws:

Exception

channel

public org.jboss.netty.channel.Channel channel(Integer id)

numberOfOpenChannels

public long numberOfOpenChannels()

totalChannels

public long totalChannels()

close

public void close()