akka.remote.testconductor
Class PlayerHandler
java.lang.Object
org.jboss.netty.channel.SimpleChannelUpstreamHandler
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 |
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)
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)