public class ConductorHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
INTERNAL API.
Constructor and Description |
---|
ConductorHandler(akka.util.Timeout _createTimeout,
akka.actor.ActorRef controller,
akka.event.LoggingAdapter log) |
Modifier and Type | Method and Description |
---|---|
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) |
java.util.concurrent.ConcurrentHashMap<org.jboss.netty.channel.Channel,akka.actor.ActorRef> |
clients() |
akka.util.Timeout |
createTimeout() |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent event) |
public ConductorHandler(akka.util.Timeout _createTimeout, akka.actor.ActorRef controller, akka.event.LoggingAdapter log)
public akka.util.Timeout createTimeout()
public java.util.concurrent.ConcurrentHashMap<org.jboss.netty.channel.Channel,akka.actor.ActorRef> clients()
public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
channelConnected
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
public void channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent event)
channelDisconnected
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)
messageReceived
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler