Package akka.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 ListenersListeners 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 voidakka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)voidgossip(java.lang.Object msg, ActorRef sender)Sends the supplied message to all current listeners using the provided sender() as sender.ActorRefgossip$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()
-
-
-
Method Detail
-
akka$routing$Listeners$_setter_$listeners_$eq
void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
-
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()
-
-