Ejemplo de Akka EventBus para Java

Question

¿Necesitas algún consejo sobre cómo usar EventBus proporcionado por Akka en Java (no Scala!). La documentación en el sitio web parece ser incompleta: http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html

Por lo que he entendido, el actor debe crearse reaccionar ante los mensajes específicos, como:

final ActorSystem actorSystem = ActorSystem.create("ServerEvents"); 
final ActorRef actor = actorSystem.actorOf(new Props(SeverEventHandler.class)); 
actorSystem.eventStream().subscribe(actor,ServerMessage.class); 

Pero ahora no está claro cómo enviar un mensaje a el autobús del evento.

¿Alguien puede compartir algunos buenos tutoriales/ejemplos/etc.?

Answer 1

Creo que eres sólo una línea corta:

final ActorSystem actorSystem = ActorSystem.create("ServerEvents"); 
final ActorRef actor = actorSystem.actorOf(new Props(SeverEventHandler.class)); 
actorSystem.eventStream().subscribe(actor,ServerMessage.class); 

actorSystem.eventStream().publish(new ServerMessage()); <<== add this 

Mientras ServerEventHandler debe ser algo como

public class ServerEventHandler extends UntypedActor { 
    @Override 
    public void onReceive(final Object message) { 
    System.out.println("Got event in thread: " + Thread.currentThread().getName()); 
    System.out.println("Event: " + message); 
    } 
}