akka.remote.testconductor

Class ConductorHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

akka.remote.testconductor.ConductorHandler

All Implemented Interfaces:

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

public class ConductorHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler

This handler is installed at the end of the controller’s netty pipeline. Its only purpose is to dispatch incoming messages to the right ServerFSM actor. There is one shared instance of this class for all connections accepted by one Controller.

INTERNAL API.

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
ConductorHandler(Timeout _createTimeout, ActorRef controller, LoggingAdapter log)

Method Summary

Modifier and Type	Method and Description
void	channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
void	channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
java.util.concurrent.ConcurrentHashMap<org.jboss.netty.channel.Channel,ActorRef>	clients()
Timeout	createTimeout()
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)

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

channelBound, channelClosed, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, exceptionCaught, handleUpstream, writeComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

ConductorHandler

public ConductorHandler(Timeout _createTimeout,
                        ActorRef controller,
                        LoggingAdapter log)

Method Detail

createTimeout

public Timeout createTimeout()

clients

public java.util.concurrent.ConcurrentHashMap<org.jboss.netty.channel.Channel,ActorRef> clients()

channelConnected

public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                             org.jboss.netty.channel.ChannelStateEvent event)

Overrides:

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

channelDisconnected

public void channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                                org.jboss.netty.channel.ChannelStateEvent event)

Overrides:

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

messageReceived

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

Overrides:

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