Interface | Description |
---|---|
Receiver.Command<T> | |
Receiver.InternalCommand<T> | |
Receiver.Replies<T> | |
Receptionist.AbstractServiceKey |
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). |
Receptionist.Command |
The set of commands accepted by a Receptionist.
|
Receptionist.ServiceKey<T> |
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).
|
Class | Description |
---|---|
Receiver | |
Receiver.ExternalAddress<T> |
Retrieve the external address of this Receiver (i.e.
|
Receiver.ExternalAddress$ | |
Receiver.GetAll<T> |
Retrieve all messages from the Receiver that it has queued after the given
duration has elapsed.
|
Receiver.GetAll$ | |
Receiver.GetAllResult<T> | |
Receiver.GetAllResult$ | |
Receiver.GetOne<T> |
Retrieve one message from the Receiver, waiting at most for the given duration.
|
Receiver.GetOne$ | |
Receiver.GetOneResult<T> | |
Receiver.GetOneResult$ | |
Receiver.ReceiveTimeout<T> | |
Receiver.ReceiveTimeout$ | |
Receiver$ | |
Receptionist | |
Receptionist.Find<T> |
Query the Receptionist for a list of all Actors implementing the given
protocol.
|
Receptionist.Find$ | |
Receptionist.Listing<T> |
Current listing of all Actors that implement the protocol given by the
Receptionist.ServiceKey . |
Receptionist.Listing$ | |
Receptionist.Register<T> |
Associate the given
ActorRef with the given Receptionist.ServiceKey . |
Receptionist.Register$ | |
Receptionist.Registered<T> |
Confirmation that the given
ActorRef has been associated with the Receptionist.ServiceKey . |
Receptionist.Registered$ | |
Receptionist$ |
A Receptionist is an entry point into an Actor hierarchy where select Actors
publish their identity together with the protocols that they implement.
|
Restarter<T,Thr extends java.lang.Throwable> |
Simple supervision strategy that restarts the underlying behavior for all
failures of type Thr.
|
Restarter.Apply<Thr extends java.lang.Throwable> | |
Restarter$ |