Package 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 theClientFSM
.INTERNAL API.
-
-
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)
-
-
-
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 classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
channelClosed
public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
- Overrides:
channelClosed
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
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
-
channelOpen
public void channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
- Overrides:
channelOpen
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
channelUnbound
public void channelUnbound(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
- Overrides:
channelUnbound
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
exceptionCaught
public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent event)
- Overrides:
exceptionCaught
in classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
messageReceived
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)
- Overrides:
messageReceived
in classorg.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 classorg.jboss.netty.channel.SimpleChannelUpstreamHandler
-
-