Class Receptionist$


  • public class Receptionist$
    extends ExtensionId<Receptionist>
    A Receptionist is an entry point into an Actor hierarchy where select Actors publish their identity together with the protocols that they implement. Other Actors need only know the Receptionist&rsquo;s identity in order to be able to use the services of the registered Actors.

    These are the messages (and the extension) for interacting with the receptionist. The receptionist is easiest accessed through the system: ActorSystem.receptionist

    • Field Detail

      • MODULE$

        public static final Receptionist$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Receptionist$

        public Receptionist$()
    • Method Detail

      • createExtension

        public Receptionist createExtension​(ActorSystem<?> system)
        Description copied from class: ExtensionId
        Create the extension, will be invoked at most one time per actor system where the extension is registered.
        Specified by:
        createExtension in class ExtensionId<Receptionist>
        Parameters:
        system - (undocumented)
        Returns:
        (undocumented)
      • register

        public <T> Receptionist.Command register​(ServiceKey<T> key,
                                                 ActorRef<T> service)
        Java API: A Register message without Ack that the service was registered. Associate the given ActorRef with the given ServiceKey by sending this command to the Receptionist.ref.

        Multiple registrations can be made for the same key. De-registration is implied by the end of the referenced Actor&rsquo;s lifecycle, but it can also be explicitly deregistered before termination.

        Parameters:
        key - (undocumented)
        service - (undocumented)
        Returns:
        (undocumented)
      • register

        public <T> Receptionist.Command register​(ServiceKey<T> key,
                                                 ActorRef<T> service,
                                                 ActorRef<Receptionist.Registered> replyTo)
        Java API: A Register message with Ack that the service was registered. Associate the given ActorRef with the given ServiceKey by sending this command to the Receptionist.ref.

        Multiple registrations can be made for the same key. De-registration is implied by the end of the referenced Actor&rsquo;s lifecycle, but it can also be explicitly deregistered before termination.

        Registration will be acknowledged with the Registered message to the given replyTo actor.

        Parameters:
        key - (undocumented)
        service - (undocumented)
        replyTo - (undocumented)
        Returns:
        (undocumented)
      • registered

        public <T> Receptionist.Registered registered​(ServiceKey<T> key,
                                                      ActorRef<T> serviceInstance)
        Java API: Sent by the receptionist, available here for easier testing
        Parameters:
        key - (undocumented)
        serviceInstance - (undocumented)
        Returns:
        (undocumented)
      • deregister

        public <T> Receptionist.Command deregister​(ServiceKey<T> key,
                                                   ActorRef<T> service)
        Java API: A Deregister message without Ack that the service was unregistered
        Parameters:
        key - (undocumented)
        service - (undocumented)
        Returns:
        (undocumented)
      • deregister

        public <T> Receptionist.Command deregister​(ServiceKey<T> key,
                                                   ActorRef<T> service,
                                                   ActorRef<Receptionist.Deregistered> replyTo)
        Java API: A Deregister message with an actor that will get an ack that the service was unregistered
        Parameters:
        key - (undocumented)
        service - (undocumented)
        replyTo - (undocumented)
        Returns:
        (undocumented)
      • deregistered

        public <T> Receptionist.Deregistered deregistered​(ServiceKey<T> key,
                                                          ActorRef<T> serviceInstance)
        Java API: Sent by the receptionist, available here for easier testing
        Parameters:
        key - (undocumented)
        serviceInstance - (undocumented)
        Returns:
        (undocumented)
      • subscribe

        public <T> Receptionist.Command subscribe​(ServiceKey<T> key,
                                                  ActorRef<Receptionist.Listing> subscriber)
        Java API: Subscribe message. The given actor to service updates when this command is sent to the Receptionist.ref. When the set of instances registered for the given key changes the subscriber will be sent a Listing with the new set of instances for that service.

        The subscription will be acknowledged by sending out a first Listing. The subscription automatically ends with the termination of the subscriber.

        Parameters:
        key - (undocumented)
        subscriber - (undocumented)
        Returns:
        (undocumented)
      • find

        public <T> Receptionist.Command find​(ServiceKey<T> key,
                                             ActorRef<Receptionist.Listing> replyTo)
        Java API: Find message. Query the Receptionist for a list of all Actors implementing the given protocol at one point in time by sending this command to the Receptionist.ref.
        Parameters:
        key - (undocumented)
        replyTo - (undocumented)
        Returns:
        (undocumented)
      • listing

        public <T> Receptionist.Listing listing​(ServiceKey<T> key,
                                                java.util.Set<ActorRef<T>> serviceInstances)
        Java API: Sent by the receptionist, available here for easier testing
        Parameters:
        key - (undocumented)
        serviceInstances - (undocumented)
        Returns:
        (undocumented)
      • listing

        public <T> Receptionist.Listing listing​(ServiceKey<T> key,
                                                java.util.Set<ActorRef<T>> serviceInstances,
                                                java.util.Set<ActorRef<T>> allServiceInstances,
                                                boolean servicesWereAddedOrRemoved)
        Java API: Sent by the receptionist, available here for easier testing
        Parameters:
        key - (undocumented)
        serviceInstances - (undocumented)
        allServiceInstances - (undocumented)
        servicesWereAddedOrRemoved - (undocumented)
        Returns:
        (undocumented)