object 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’s identity in order to be able to use the services of the registered Actors.
- Source
- Receptionist.scala
- Alphabetic
- By Inheritance
- Receptionist
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
trait
AbstractServiceKey
extends AnyRef
Internal representation of Receptionist.ServiceKey which is needed in order to use a TypedMultiMap (using keys with a type parameter does not work in Scala 2.x).
-
sealed
trait
Command
extends AnyRef
The set of commands accepted by a Receptionist.
-
final
case class
Find
[T](key: ServiceKey[T])(replyTo: ActorRef[Listing[T]]) extends Command with Product with Serializable
Query the Receptionist for a list of all Actors implementing the given protocol.
-
final
case class
Listing
[T](key: ServiceKey[T], addresses: Set[ActorRef[T]]) extends Product with Serializable
Current listing of all Actors that implement the protocol given by the ServiceKey.
-
final
case class
Register
[T](key: ServiceKey[T], address: ActorRef[T])(replyTo: ActorRef[Registered[T]]) extends Command with Product with Serializable
Associate the given akka.typed.ActorRef with the given ServiceKey.
Associate the given akka.typed.ActorRef with the given ServiceKey. Multiple registrations can be made for the same key. Unregistration is implied by the end of the referenced Actor’s lifecycle.
-
final
case class
Registered
[T](key: ServiceKey[T], address: ActorRef[T]) extends Product with Serializable
Confirmation that the given akka.typed.ActorRef has been associated with the ServiceKey.
-
trait
ServiceKey
[T] extends AbstractServiceKey
A service key is an object that implements this trait for a given protocol T, meaning that it signifies that the type T is the entry point into the protocol spoken by that service (think of it as the set of first messages that a client could send).
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
behavior: Behavior[Command]
Initial behavior of a receptionist, used to create a new receptionist like in the following:
Initial behavior of a receptionist, used to create a new receptionist like in the following:
val receptionist: ActorRef[Receptionist.Command] = ctx.spawn(Props(Receptionist.behavior), "receptionist")
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )