Package 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.
-
-
Constructor Summary
Constructors Constructor Description ConductorHandler(Timeout _createTimeout, ActorRef controller, LoggingAdapter log)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Constructor Detail
-
ConductorHandler
public ConductorHandler(Timeout _createTimeout, ActorRef controller, LoggingAdapter log)
-
-
Method Detail
-
channelConnected
public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
- Overrides:
channelConnected
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
channelDisconnected
public void channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
- Overrides:
channelDisconnected
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
clients
public java.util.concurrent.ConcurrentHashMap<org.jboss.netty.channel.Channel,ActorRef> clients()
-
createTimeout
public Timeout createTimeout()
-
messageReceived
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)
- Overrides:
messageReceived
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
-