public class TcpListener extends java.lang.Object implements Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>
Modifier and Type | Class and Description |
---|---|
static class |
TcpListener.FailedRegisterIncoming |
static class |
TcpListener.FailedRegisterIncoming$ |
static class |
TcpListener.RegisterIncoming |
static class |
TcpListener.RegisterIncoming$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
TcpListener(ActorRef selectorRouter,
TcpExt tcp,
ChannelRegistry channelRegistry,
ActorRef bindCommander,
Tcp.Bind bind) |
Modifier and Type | Method and Description |
---|---|
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, unhandled
_log, log
public TcpListener(ActorRef selectorRouter, TcpExt tcp, ChannelRegistry channelRegistry, ActorRef bindCommander, Tcp.Bind bind)
public java.nio.channels.ServerSocketChannel channel()
public int acceptLimit()
public java.lang.Object localAddress()
public SupervisorStrategy supervisorStrategy()
Actor
supervisorStrategy
in interface Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> bound(ChannelRegistration registration)
public final int acceptAllPending(ChannelRegistration registration, int limit)