akka.io
Class TcpListener

java.lang.Object
  extended by akka.io.TcpListener
All Implemented Interfaces:
Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>

public class TcpListener
extends java.lang.Object
implements Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>

INTERNAL API


Nested Class Summary
static class TcpListener.FailedRegisterIncoming
           
static class TcpListener.FailedRegisterIncoming$
           
static class TcpListener.RegisterIncoming
           
static class TcpListener.RegisterIncoming$
           
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
TcpListener(ActorRef selectorRouter, TcpExt tcp, ChannelRegistry channelRegistry, ActorRef bindCommander, Tcp.Bind bind)
           
 
Method Summary
 int acceptAllPending(ChannelRegistration registration, int limit)
           
 int acceptLimit()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> bound(ChannelRegistration registration)
           
 java.nio.channels.ServerSocketChannel channel()
           
 java.lang.Object localAddress()
           
 void postStop()
          User overridable callback.
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 SupervisorStrategy supervisorStrategy()
          User overridable definition the strategy to use for supervising child actors.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, unhandled
 
Methods inherited from interface akka.actor.ActorLogging
_log, log
 

Constructor Detail

TcpListener

public TcpListener(ActorRef selectorRouter,
                   TcpExt tcp,
                   ChannelRegistry channelRegistry,
                   ActorRef bindCommander,
                   Tcp.Bind bind)
Method Detail

channel

public java.nio.channels.ServerSocketChannel channel()

acceptLimit

public int acceptLimit()

localAddress

public java.lang.Object localAddress()

supervisorStrategy

public SupervisorStrategy supervisorStrategy()
Description copied from interface: Actor
User overridable definition the strategy to use for supervising child actors.

Specified by:
supervisorStrategy in interface Actor
Returns:
(undocumented)

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface: Actor
This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:
receive in interface Actor
Returns:
(undocumented)

bound

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> bound(ChannelRegistration registration)

acceptAllPending

public final int acceptAllPending(ChannelRegistration registration,
                                  int limit)

postStop

public void postStop()
Description copied from interface: Actor
User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:
postStop in interface Actor