akka.remote.testconductor
Class PlayerHandler

java.lang.Object
  extended by org.jboss.netty.channel.SimpleChannelUpstreamHandler
      extended by akka.remote.testconductor.PlayerHandler

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

This handler only forwards messages received from the conductor to the ClientFSM.

INTERNAL API.


Constructor Summary
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
 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 writeComplete(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.WriteCompletionEvent event)
           
 
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

nextAttempt

public scala.concurrent.duration.Deadline nextAttempt()

channelOpen

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

channelClosed

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

channelBound

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

channelUnbound

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

writeComplete

public void writeComplete(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.WriteCompletionEvent event)

exceptionCaught

public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.ExceptionEvent event)

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)