public class UdpListener extends java.lang.Object implements Actor, ActorLogging, WithUdpSend, RequiresMessageQueue<UnboundedMessageQueueSemantics>
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
UdpListener(UdpExt udp,
ChannelRegistry channelRegistry,
ActorRef bindCommander,
Udp.Bind bind) |
Modifier and Type | Method and Description |
---|---|
java.nio.channels.DatagramChannel |
channel() |
void |
doReceive(ChannelRegistration registration,
ActorRef handler) |
java.lang.Object |
localAddress() |
void |
postStop()
User overridable callback.
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
readHandlers(ChannelRegistration registration) |
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.
|
ActorRef |
selector() |
UdpExt |
udp() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
_log, log
doSend, hasWritePending, pendingCommander, pendingSend, retriedSend, sendHandlers, settings
public UdpListener(UdpExt udp, ChannelRegistry channelRegistry, ActorRef bindCommander, Udp.Bind bind)
public UdpExt udp()
udp
in interface WithUdpSend
public ActorRef selector()
public java.nio.channels.DatagramChannel channel()
channel
in interface WithUdpSend
public java.lang.Object localAddress()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> readHandlers(ChannelRegistration registration)
public void doReceive(ChannelRegistration registration, ActorRef handler)