Package akka.actor.typed.receptionist

Class Receptionist$

java.lang.Object

akka.actor.typed.ExtensionId<Receptionist>

akka.actor.typed.receptionist.Receptionist$

public class Receptionist$
extends ExtensionId<Receptionist>

The set of commands accepted by a Receptionist.

Not for user Extension

Field Summary

Fields

Modifier and Type	Field	Description
static Receptionist$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
Receptionist$()

Method Summary

Modifier and Type	Method	Description
Receptionist	createExtension(ActorSystem<?> system)
<T> Receptionist.Command	find(ServiceKey<T> key, ActorRef<Receptionist.Listing> replyTo)
Receptionist	get(ActorSystem<?> system)
<T> Receptionist.Listing	listing(ServiceKey<T> key, java.util.Set<ActorRef<T>> serviceInstances)
<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
<T> Receptionist.Command	register(ServiceKey<T> key, ActorRef<T> service)
<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.
<T> Receptionist.Registered	registered(ServiceKey<T> key, ActorRef<T> serviceInstance)
<T> Receptionist.Command	subscribe(ServiceKey<T> key, ActorRef<Receptionist.Listing> subscriber)

Methods inherited from class akka.actor.typed.ExtensionId

apply, equals, hashCode, id

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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)

Specified by:

createExtension in class ExtensionId<Receptionist>

get

public Receptionist get(ActorSystem<?> system)

register

public <T> Receptionist.Command register(ServiceKey<T> key,
                                         ActorRef<T> service)

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.

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)

subscribe

public <T> Receptionist.Command subscribe(ServiceKey<T> key,
                                          ActorRef<Receptionist.Listing> subscriber)

find

public <T> Receptionist.Command find(ServiceKey<T> key,
                                     ActorRef<Receptionist.Listing> replyTo)

listing

public <T> Receptionist.Listing listing(ServiceKey<T> key,
                                        java.util.Set<ActorRef<T>> serviceInstances)

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)