Package akka.remote.testconductor

Class PlayerHandler

  • All Implemented Interfaces:
    org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler
    public class PlayerHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
    This handler only forwards messages received from the conductor to the ClientFSM.

    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 Description
      PlayerHandler​(java.net.InetSocketAddress server, int reconnects, scala.concurrent.duration.FiniteDuration backoff, int poolSize, ActorRef fsm, LoggingAdapter log, Scheduler scheduler, scala.concurrent.ExecutionContext executor)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelBound​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)  
      void channelClosed​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)  
      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)  
      void channelOpen​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)  
      void channelUnbound​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)  
      void exceptionCaught​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent event)  
      void messageReceived​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)  
      scala.concurrent.duration.Deadline nextAttempt()  
      void nextAttempt_$eq​(scala.concurrent.duration.Deadline x$1)  
      void writeComplete​(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.WriteCompletionEvent event)  

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

        channelInterestChanged, childChannelClosed, childChannelOpen, handleUpstream

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • PlayerHandler

        public PlayerHandler​(java.net.InetSocketAddress server,
                     int reconnects,
                     scala.concurrent.duration.FiniteDuration backoff,
                     int poolSize,
                     ActorRef fsm,
                     LoggingAdapter log,
                     Scheduler scheduler,
                     scala.concurrent.ExecutionContext executor)

    • Method Detail

      • channelBound

        public void channelBound​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                         org.jboss.netty.channel.ChannelStateEvent event)
        Overrides:
        channelBound in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

      • channelClosed

        public void channelClosed​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.ChannelStateEvent event)
        Overrides:
        channelClosed in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

      • 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

      • channelOpen

        public void channelOpen​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                        org.jboss.netty.channel.ChannelStateEvent event)
        Overrides:
        channelOpen in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

      • channelUnbound

        public void channelUnbound​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                           org.jboss.netty.channel.ChannelStateEvent event)
        Overrides:
        channelUnbound in class org.jboss.netty.channel.SimpleChannelUpstreamHandler

      • exceptionCaught

        public void exceptionCaught​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.ExceptionEvent event)
        Overrides:
        exceptionCaught 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

      • nextAttempt

        public scala.concurrent.duration.Deadline nextAttempt()

      • nextAttempt_$eq

        public void nextAttempt_$eq​(scala.concurrent.duration.Deadline x$1)

      • writeComplete

        public void writeComplete​(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.WriteCompletionEvent event)
        Overrides:
        writeComplete in class org.jboss.netty.channel.SimpleChannelUpstreamHandler