public class EventTest {

    public static void main(String[] args) {
        EventService.init(null);
        EventService.registerEventHandler("time", new TimeEventHandle());

        for (int i = 0; i < 5; i++) {
            Event e = new Event("time", System.currentTimeMillis());

            EventService.fireEvent(e);
            System.out.println("Публикуется событие: " + e.getId());
            Lang.sleep(100);
        }
        System.out.println("События опубликованы");
        EventService.stop();
    }

}

public class TimeEventHandle implements EventHandler {

    private static Logger log = LoggerFactory.getLogger(TimeEventHandle.class);

    @Override
    public Object onEvent(Event event) {
        log.debug("Сообщение: " + event.getId() + " " + event.getParam());
        Lang.sleep(R.random(1, 20) * 100);
        log.debug("Сообщение: " + event.getId() + " Обработка завершена");
        return null;
    }

}