akka.remote.testconductor

Class PlayerHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

akka.remote.testconductor.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 and 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

Modifier and Type	Method and 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	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

nextAttempt

public scala.concurrent.duration.Deadline nextAttempt()

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

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

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

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

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

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

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

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