included imports also
This commit is contained in:
parent
6537c75625
commit
1e28baaada
2 changed files with 15 additions and 4 deletions
|
|
@ -51,6 +51,11 @@ The messages sent to this Actor are:
|
||||||
So your listener Actor needs to be able to handle these two messages. Example:
|
So your listener Actor needs to be able to handle these two messages. Example:
|
||||||
|
|
||||||
.. code-block:: java
|
.. code-block:: java
|
||||||
|
import akka.actor.ActorRegistered;
|
||||||
|
import akka.actor.ActorUnregistered;
|
||||||
|
import akka.actor.UntypedActor;
|
||||||
|
import akka.event.EventHandler;
|
||||||
|
|
||||||
public class RegistryListener extends UntypedActor {
|
public class RegistryListener extends UntypedActor {
|
||||||
public void onReceive(Object message) throws Exception {
|
public void onReceive(Object message) throws Exception {
|
||||||
if (message instanceof ActorRegistered) {
|
if (message instanceof ActorRegistered) {
|
||||||
|
|
|
||||||
|
|
@ -77,7 +77,13 @@ The messages sent to this Actor are:
|
||||||
|
|
||||||
So your listener Actor needs to be able to handle these two messages. Example:
|
So your listener Actor needs to be able to handle these two messages. Example:
|
||||||
|
|
||||||
.. code-block:: java
|
.. code-block:: scala
|
||||||
|
import akka.actor.Actor
|
||||||
|
import akka.actor.ActorRegistered;
|
||||||
|
import akka.actor.ActorUnregistered;
|
||||||
|
import akka.actor.UntypedActor;
|
||||||
|
import akka.event.EventHandler;
|
||||||
|
|
||||||
class RegistryListener extends Actor {
|
class RegistryListener extends Actor {
|
||||||
def receive = {
|
def receive = {
|
||||||
case event: ActorRegistered =>
|
case event: ActorRegistered =>
|
||||||
|
|
@ -87,12 +93,12 @@ class RegistryListener extends Actor {
|
||||||
// ...
|
// ...
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
.. code-block:: java
|
.. code-block:: scala
|
||||||
The above actor can be added as listener of registry events:
|
The above actor can be added as listener of registry events:
|
||||||
.. code-block:: java
|
.. code-block:: scala
|
||||||
import akka.actor._
|
import akka.actor._
|
||||||
import akka.actor.Actor._
|
import akka.actor.Actor._
|
||||||
|
|
||||||
val listener = actorOf[RegistryListener].start
|
val listener = actorOf[RegistryListener].start
|
||||||
registry.addListener(listener)
|
registry.addListener(listener)
|
||||||
.. code-block:: java
|
.. code-block:: scala
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue