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.

Nested Class Summary

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

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private int	attempts
private org.jboss.netty.bootstrap.ClientBootstrap	bootstrap
private org.jboss.netty.channel.Channel	channel
private org.jboss.netty.channel.group.ChannelGroup	channels
private boolean	reconnect
private org.jboss.netty.util.Timer	timer

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

Field Detail

bootstrap

private org.jboss.netty.bootstrap.ClientBootstrap bootstrap

channel

private org.jboss.netty.channel.Channel channel

channels

private org.jboss.netty.channel.group.ChannelGroup channels

timer

private org.jboss.netty.util.Timer timer

reconnect

private boolean reconnect

attempts

private int attempts

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 java.lang.Exception

Overrides:

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

Throws:

java.lang.Exception

channelClosed

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

Overrides:

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

Throws:

java.lang.Exception

exceptionCaught

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

Overrides:

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

Throws:

java.lang.Exception

run

public void run(org.jboss.netty.util.Timeout timeout)
         throws java.lang.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:

java.lang.Exception - when reconnection fails.