Beispiel für Akka EventBus für Java

Question

Brauchen Sie einen Hinweis, wie EventBus von Akka in Java (nicht Scala!) Verwendet werden soll. Die Dokumentation auf der Website scheint unvollständig zu sein: http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html

Soweit ich verstand, Schauspieler sollten auf bestimmte Nachrichten, wie zu reagieren erstellt werden: es ist nicht klar

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

Aber jetzt, wie eine Nachricht senden der Eventbus.

Kann jemand bitte einige gute Tutorials/Beispiele/etc teilen?

Answer 1

Ich glaube, Sie sind nur eine Zeile kurz:

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 

Während ServerEventHandler so etwas wie

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); 
    } 
}