Package org.apache.pekko.event

Interface ManagedActorClassification

public interface ManagedActorClassification
Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs.

All subscribers will be watched by an org.apache.pekko.event.ActorClassificationUnsubscriber and unsubscribed when they terminate. The unsubscriber actor will not be stopped automatically, and if you want to stop using the bus you should stop it yourself.

  • Method Details

    • associate

      boolean associate(ActorRef monitored, ActorRef monitor)

    • classify

      ActorRef classify(ManagedActorClassification event)
      Returns the Classifier associated with the specified Event

    • dissociate

      void dissociate(ActorRef actor)

    • dissociate

      boolean dissociate(ActorRef monitored, ActorRef monitor)

    • mapSize

      int mapSize()
      This is a size hint for the number of Classifiers you expect to have (use powers of 2)

    • publish

      void publish(ManagedActorClassification event)

    • registerWithUnsubscriber

      boolean registerWithUnsubscriber(ActorRef subscriber, int seqNr)
      INTERNAL API

    • subscribe

      boolean subscribe(ActorRef subscriber, ActorRef to)

    • system

      ActorSystem system()

    • unregisterFromUnsubscriber

      boolean unregisterFromUnsubscriber(ActorRef subscriber, int seqNr)
      INTERNAL API

    • unsubscribe

      boolean unsubscribe(ActorRef subscriber, ActorRef from)

    • unsubscribe

      void unsubscribe(ActorRef subscriber)

    • unsubscriber

      ActorRef unsubscriber()
      The unsubscriber takes care of unsubscribing actors, which have terminated.