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
All Methods Instance Methods Concrete Methods 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.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
-
-
-
-
Field Detail
-
MODULE$
public static final Receptionist$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
createExtension
public Receptionist createExtension(ActorSystem<?> system)
- Specified by:
createExtension
in classExtensionId<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- 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)
-
-