我需要一些关于如何在 Java(不是 Scala!)中使用 Akka 提供的 EventBus 的建议。我在http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html中看到了文档
我试着自己做,所以我在这里得到了这些代码:
public class Subscriber {
public static void main(String args[]){
final ActorSystem actorSystem = ActorSystem.create("ServerEvents");
final ActorRef actor = actorSystem.actorOf(new Props(ServerEventHandler.class));
actorSystem.eventStream().subscribe(actor,ServerMessage.class);
actorSystem.eventStream().publish(new ServerMessage());
}
}
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);
}
}
问题是,我知道
actorSystem.eventStream().subscribe(actor,ServerMessage.class);
actorSystem.eventStream().publish(new ServerMessage());
ServerMessage() 是 sub/pub 的通道和消息,但是 Class ServerMessage 中的确切内容是什么?
如果你们能提供帮助将不胜感激
谢谢!