Package org.jboss.netty.handler.timeout

Class ReadTimeoutHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.jboss.netty.handler.timeout.ReadTimeoutHandler

All Implemented Interfaces:

ChannelHandler, ChannelUpstreamHandler, LifeCycleAwareChannelHandler, ExternalResourceReleasable

@Sharable
public class ReadTimeoutHandler
extends SimpleChannelUpstreamHandler
implements LifeCycleAwareChannelHandler, ExternalResourceReleasable

Raises a ReadTimeoutException when no data was read within a certain period of time.

 public class MyPipelineFactory implements ChannelPipelineFactory {

     private final Timer timer;
     private final ChannelHandler timeoutHandler;

     public MyPipelineFactory(Timer timer) {
         this.timer = timer;
         this.timeoutHandler = new ReadTimeoutHandler(timer, 30), // timer must be shared.
     }

     public ChannelPipeline getPipeline() {
         // An example configuration that implements 30-second read timeout:
         return Channels.pipeline(
             timeoutHandler,
             new MyHandler());
     }
 }

 ServerBootstrap bootstrap = ...;
 Timer timer = new HashedWheelTimer();
 ...
 bootstrap.setPipelineFactory(new MyPipelineFactory(timer));
 ...
 

The Timer which was specified when the ReadTimeoutHandler is created should be stopped manually by calling releaseExternalResources() or Timer.stop() when your application shuts down.

See Also:

WriteTimeoutHandler, IdleStateHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ReadTimeoutHandler.ReadTimeoutTask
private static class	ReadTimeoutHandler.State

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

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static ReadTimeoutException	EXCEPTION
(package private) long	timeoutMillis
(package private) Timer	timer

Constructor Summary

Constructors

Constructor	Description
ReadTimeoutHandler(Timer timer, int timeoutSeconds)	Creates a new instance.
ReadTimeoutHandler(Timer timer, long timeout, java.util.concurrent.TimeUnit unit)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
void	afterAdd(ChannelHandlerContext ctx)
void	afterRemove(ChannelHandlerContext ctx)
void	beforeAdd(ChannelHandlerContext ctx)
void	beforeRemove(ChannelHandlerContext ctx)
void	channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e)	Invoked when a Channel was closed and all its related resources were released.
void	channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)	Invoked when a Channel is open, but not bound nor connected.
private static void	destroy(ChannelHandlerContext ctx)
private void	initialize(ChannelHandlerContext ctx)
void	messageReceived(ChannelHandlerContext ctx, MessageEvent e)	Invoked when a message object (e.g: ChannelBuffer) was received from a remote peer.
protected void	readTimedOut(ChannelHandlerContext ctx)
void	releaseExternalResources()	Stops the Timer which was specified in the constructor of this handler.
private static ReadTimeoutHandler.State	state(ChannelHandlerContext ctx)

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

channelBound, channelConnected, channelDisconnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, exceptionCaught, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

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

Field Detail

EXCEPTION

static final ReadTimeoutException EXCEPTION

timer

final Timer timer

timeoutMillis

final long timeoutMillis

Constructor Detail

ReadTimeoutHandler

public ReadTimeoutHandler(Timer timer,
                          int timeoutSeconds)

Creates a new instance.

Parameters:

timer - the Timer that is used to trigger the scheduled event. The recommended Timer implementation is HashedWheelTimer.

timeoutSeconds - read timeout in seconds

ReadTimeoutHandler

public ReadTimeoutHandler(Timer timer,
                          long timeout,
                          java.util.concurrent.TimeUnit unit)

Creates a new instance.

Parameters:

timer - the Timer that is used to trigger the scheduled event. The recommended Timer implementation is HashedWheelTimer.

timeout - read timeout

unit - the TimeUnit of timeout

Method Detail

releaseExternalResources

public void releaseExternalResources()

Stops the Timer which was specified in the constructor of this handler. You should not call this method if the Timer is in use by other objects.

Specified by:

releaseExternalResources in interface ExternalResourceReleasable

beforeAdd

public void beforeAdd(ChannelHandlerContext ctx)
               throws java.lang.Exception

Specified by:

beforeAdd in interface LifeCycleAwareChannelHandler

Throws:

java.lang.Exception

afterAdd

public void afterAdd(ChannelHandlerContext ctx)
              throws java.lang.Exception

Specified by:

afterAdd in interface LifeCycleAwareChannelHandler

Throws:

java.lang.Exception

beforeRemove

public void beforeRemove(ChannelHandlerContext ctx)
                  throws java.lang.Exception

Specified by:

beforeRemove in interface LifeCycleAwareChannelHandler

Throws:

java.lang.Exception

afterRemove

public void afterRemove(ChannelHandlerContext ctx)
                 throws java.lang.Exception

Specified by:

afterRemove in interface LifeCycleAwareChannelHandler

Throws:

java.lang.Exception

channelOpen

public void channelOpen(ChannelHandlerContext ctx,
                        ChannelStateEvent e)
                 throws java.lang.Exception

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a Channel is open, but not bound nor connected.
Be aware that this event is fired from within the I/O thread. You should never execute any heavy operation in there as it will block the dispatching to other workers!

Overrides:

channelOpen in class SimpleChannelUpstreamHandler

Throws:

java.lang.Exception

channelClosed

public void channelClosed(ChannelHandlerContext ctx,
                          ChannelStateEvent e)
                   throws java.lang.Exception

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a Channel was closed and all its related resources were released.

Overrides:

channelClosed in class SimpleChannelUpstreamHandler

Throws:

java.lang.Exception

messageReceived

public void messageReceived(ChannelHandlerContext ctx,
                            MessageEvent e)
                     throws java.lang.Exception

Description copied from class: SimpleChannelUpstreamHandler

Invoked when a message object (e.g: ChannelBuffer) was received from a remote peer.

Overrides:

messageReceived in class SimpleChannelUpstreamHandler

Throws:

java.lang.Exception

initialize

private void initialize(ChannelHandlerContext ctx)

destroy

private static void destroy(ChannelHandlerContext ctx)

state

private static ReadTimeoutHandler.State state(ChannelHandlerContext ctx)

readTimedOut

protected void readTimedOut(ChannelHandlerContext ctx)
                     throws java.lang.Exception

Throws:

java.lang.Exception