akka.remote.testconductor
Class ConductorHandler

java.lang.Object
  org.jboss.netty.channel.SimpleChannelUpstreamHandler
      akka.remote.testconductor.ConductorHandler

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.

Constructor Summary

ConductorHandler(Timeout _createTimeout, ActorRef controller, LoggingAdapter log)

Method Summary

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 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)

channelDisconnected

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

messageReceived

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