Akka EventBus for Javaの例

Question

JavaでAkkaが提供するEventBus（Scalaではなく）を使用する方法のアドバイスが必要です。ウェブサイト上のドキュメントが不完全であると思わ：http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html

私の知る限り理解されるように、俳優は次のように、特定のメッセージに反応するように作成する必要があります。

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

しかし、今、それはにメッセージを送信する方法は明らかではありませんイベントバス。

誰かが良いチュートリアル/例/などを教えていただけますか？

私はあなただけの1行の短いだと思う

Answer 1

：

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 

ServerEventHandlerが

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