发布订阅模型

EventBus bus = EventBus.create(Environment.get()); 

bus.on($("topic"), (Event<String> ev) -> {
  String s = ev.getData();
  System.out.printf("Got %s on thread %s%n", s, Thread.currentThread());
}); 

bus.notify("topic", Event.wrap("Hello World!"));