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 the gossip(msg) method to have it sent to the listeners.

Send Listen(self) to start listening.

Send Deafen(self) to stop listening.

Send WithListeners(fun) to traverse the current listeners.

  • Method Details

    • gossip

      void gossip(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(Object msg)

    • listenerManagement

      scala.PartialFunction<Object,scala.runtime.BoxedUnit> listenerManagement()
      Chain this into the receive function. 

       def receive = listenerManagement orElse …

    • listeners

      Set<ActorRef> listeners()

    • org$apache$pekko$routing$Listeners$_setter_$listeners_$eq

      void org$apache$pekko$routing$Listeners$_setter_$listeners_$eq(Set<ActorRef> x$1)