akka.io
Class TcpListener
java.lang.Object
akka.io.TcpListener
- All Implemented Interfaces:
- Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>
public class TcpListener
- extends java.lang.Object
- implements Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>
INTERNAL API
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 |
TcpListener
public TcpListener(ActorRef selectorRouter,
TcpExt tcp,
ChannelRegistry channelRegistry,
ActorRef bindCommander,
Tcp.Bind bind)
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