Package akka.actor.typed.receptionist

Class Receptionist

java.lang.Object

akka.actor.typed.receptionist.Receptionist

All Implemented Interfaces:

Extension

Direct Known Subclasses:

ReceptionistImpl

public abstract class Receptionist
extends java.lang.Object
implements Extension

This class is not intended for user extension other than for test purposes (e.g. stub implementation). More methods may be added in the future and that may break such implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Receptionist.Command	The set of commands accepted by a Receptionist.
static class	Receptionist.Find$	Scala API:
static interface	Receptionist.Listing	Scala API
static class	Receptionist.Listing$
static class	Receptionist.Register$
static interface	Receptionist.Registered	Scala API
static class	Receptionist.Registered$
static class	Receptionist.Subscribe$	Scala API:

Constructor Summary

Constructors

Constructor	Description
Receptionist()

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem<?> system)
static Receptionist	createExtension(ActorSystem<?> system)
static boolean	equals(java.lang.Object other)
static <T> Receptionist.Command	find(ServiceKey<T> key, ActorRef<Receptionist.Listing> replyTo)
static Receptionist	get(ActorSystem<?> system)
static int	hashCode()
static ExtensionId<T>	id()
static <T> Receptionist.Listing	listing(ServiceKey<T> key, java.util.Set<ActorRef<T>> serviceInstances)
abstract ActorRef<Receptionist.Command>	ref()
static <T> Receptionist.Command	register(ServiceKey<T> key, ActorRef<T> service)
static <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
static <T> Receptionist.Registered	registered(ServiceKey<T> key, ActorRef<T> serviceInstance)
static <T> Receptionist.Command	subscribe(ServiceKey<T> key, ActorRef<Receptionist.Listing> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Detail

Receptionist

public Receptionist()

Method Detail

createExtension

public static Receptionist createExtension(ActorSystem<?> system)

get

public static Receptionist get(ActorSystem<?> system)

register

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

register

public static <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 static <T> Receptionist.Registered registered(ServiceKey<T> key,
                                                     ActorRef<T> serviceInstance)

subscribe

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

find

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

listing

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

apply

public static final T apply(ActorSystem<?> system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

id

public static ExtensionId<T> id()

ref

public abstract ActorRef<Receptionist.Command> ref()