@Test public void post() throws Exception { prickleSink.latch = new CountDownLatch(1); dispatcher.post(new Prickle("yo")); prickleSink.latch.await(100, TimeUnit.MILLISECONDS); validate(prickleSink, "yo"); validate(gooSink); }
@Override public void post(Event event) { if (!events.add(event)) { log.error("Unable to post event {}", event); } }
CoreEventDispatcher extends DefaultEventSinkRegistry implements EventDeliveryService { @Override public void post(Event event) { if (!events.add(event)) { log.error("Unable to post event {}", event); } } }
CoreEventDispatcher extends DefaultEventSinkRegistry implements EventDeliveryService { @Override public void post(Event event) { if (!events.add(event)) { log.error("Unable to post event {}", event); } }  }
CoreEventDispatcher extends DefaultEventSinkRegistry implements EventDeliveryService { @Override public void post(Event event) { if (!events.add(event)) { log.error("Unable to post event {}", event); } }  @Override void post(Event event); @Activate void activate(); @Deactivate void deactivate(); @Override void setDispatchTimeLimit(long millis); @Override long getDispatchTimeLimit(); }
CoreEventDispatcher extends DefaultEventSinkRegistry implements EventDeliveryService { @Override public void post(Event event) { if (!events.add(event)) { log.error("Unable to post event {}", event); } }  @Override void post(Event event); @Activate void activate(); @Deactivate void deactivate(); @Override void setDispatchTimeLimit(long millis); @Override long getDispatchTimeLimit();  }