Package org.apache.pekko.routing
Interface Listeners
-
- All Known Subinterfaces:
FSM<S,D>
,LoggingFSM<S,D>
,LoggingPersistentFSM<S,D,E>
,PersistentFSM<S,D,E>
,PersistentFSMBase<S,D,E>
- All Known Implementing Classes:
AbstractFSM
,AbstractFSMWithStash
,AbstractLoggingFSM
,AbstractPersistentFSM
,AbstractPersistentFSMBase
,AbstractPersistentLoggingFSM
,ClusterSingletonManager
public interface Listeners
Listeners is a generic trait to implement listening capability on an Actor. Use thegossip(msg)
method to have it sent to the listeners. SendListen(self)
to start listening. SendDeafen(self)
to stop listening. SendWithListeners(fun)
to traverse the current listeners.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
gossip(java.lang.Object msg, ActorRef sender)
Sends the supplied message to all current listeners using the provided sender() as sender.ActorRef
gossip$default$2(java.lang.Object msg)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
listenerManagement()
Chain this into the receive function.java.util.Set<ActorRef>
listeners()
void
org$apache$pekko$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
-
-
-
Method Detail
-
gossip
void gossip(java.lang.Object msg, ActorRef sender)
Sends the supplied message to all current listeners using the provided sender() as sender.
-
gossip$default$2
ActorRef gossip$default$2(java.lang.Object msg)
-
listenerManagement
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> listenerManagement()
Chain this into the receive function.def receive = listenerManagement orElse …
-
listeners
java.util.Set<ActorRef> listeners()
-
org$apache$pekko$routing$Listeners$_setter_$listeners_$eq
void org$apache$pekko$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
-
-