io.parallec.core.actor

Class TcpWorker.TcpChannelHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelHandler

io.parallec.core.actor.TcpWorker.TcpChannelHandler

All Implemented Interfaces:

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

Enclosing class:

TcpWorker

public static class TcpWorker.TcpChannelHandler
extends org.jboss.netty.channel.SimpleChannelHandler

The Netty response/channel handler.

Author:

Yuanteng (Jeff) Pei

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
boolean	hasCaughtException The has caught exception.
private int	msgRecvCount The msg recv count.
private TcpWorker	tcpWorker The tcp worker.

Constructor Summary

Constructors

Constructor and Description
TcpChannelHandler(TcpWorker tcpWorker) Instantiates a new tcp channel handler.

Method Summary

Modifier and Type	Method and Description
void	channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e) Why not use channelClosed: if fail to establish a channel (e.g.
void	exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)

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

bindRequested, channelBound, channelClosed, channelConnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested

Methods inherited from class java.lang.Object

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

Field Detail

hasCaughtException

public boolean hasCaughtException

The has caught exception.

tcpWorker

private final TcpWorker tcpWorker

The tcp worker.

msgRecvCount

private int msgRecvCount

The msg recv count.

Constructor Detail

TcpChannelHandler

public TcpChannelHandler(TcpWorker tcpWorker)

Instantiates a new tcp channel handler.

Parameters:

tcpWorker - the tcp worker

Method Detail

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.MessageEvent e)

Overrides:

messageReceived in class org.jboss.netty.channel.SimpleChannelHandler

channelDisconnected

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

Why not use channelClosed: if fail to establish a channel (e.g. connection refused). will also call channelClosed.

Overrides:

channelDisconnected in class org.jboss.netty.channel.SimpleChannelHandler

Parameters:

ctx - the ctx

e - the e

Throws:

java.lang.Exception - the exception

exceptionCaught

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

Overrides:

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