com.lambdaworks.redis.protocol

Class ConnectionWatchdog

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

com.lambdaworks.redis.protocol.ConnectionWatchdog

All Implemented Interfaces:

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

public class ConnectionWatchdog
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
implements org.jboss.netty.util.TimerTask

A netty ChannelHandler responsible for monitoring the channel and reconnecting when the connection is lost.

Author:

Will Glozer

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
ConnectionWatchdog(org.jboss.netty.bootstrap.ClientBootstrap bootstrap, org.jboss.netty.channel.group.ChannelGroup channels, org.jboss.netty.util.Timer timer) Create a new watchdog that adds to new connections to the supplied ChannelGroup and establishes a new Channel when disconnected, while reconnect is true.

Method Summary

Modifier and Type	Method and Description
void	channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
void	run(org.jboss.netty.util.Timeout timeout) Reconnect to the remote address that the closed channel was connected to.
void	setReconnect(boolean reconnect)

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

channelBound, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream, messageReceived, writeComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionWatchdog

public ConnectionWatchdog(org.jboss.netty.bootstrap.ClientBootstrap bootstrap,
                          org.jboss.netty.channel.group.ChannelGroup channels,
                          org.jboss.netty.util.Timer timer)

Create a new watchdog that adds to new connections to the supplied ChannelGroup and establishes a new Channel when disconnected, while reconnect is true.

Parameters:

bootstrap - Configuration for new channels.

channels - ChannelGroup to add new channels to.

timer - Timer used for delayed reconnect.

Method Detail

setReconnect

public void setReconnect(boolean reconnect)

channelConnected

public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                             org.jboss.netty.channel.ChannelStateEvent e)
                      throws Exception

Overrides:

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

Throws:

Exception

channelClosed

public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.ChannelStateEvent e)
                   throws Exception

Overrides:

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

Throws:

Exception

exceptionCaught

public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.ExceptionEvent e)
                     throws Exception

Overrides:

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

Throws:

Exception

run

public void run(org.jboss.netty.util.Timeout timeout)
         throws Exception

Reconnect to the remote address that the closed channel was connected to. This creates a new ChannelPipeline with the same handler instances contained in the old channel's pipeline.

Specified by:

run in interface org.jboss.netty.util.TimerTask

Parameters:

timeout - Timer task handle.

Throws:

Exception - when reconnection fails.