Class 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
    • 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)  
      • 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
    • Method Detail

      • 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
      • 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 class org.jboss.netty.channel.SimpleChannelUpstreamHandler