reactor.java

import static reactor.Fn.$;
 
@Inject
Service service;

Reactor reactor = R.create();
 
reactor.on($("parse"), new Consumer<Event<String>>() {
  public void call(Event<String> ev) {
    service.handleEvent(ev);
  }
});
 
reactor.notify("parse", Fn.event("Hello World!"));