@Test public void postEventWithBadSink() throws Exception { gooSink.latch = new CountDownLatch(1); dispatcher.post(new Goo("boom")); gooSink.latch.await(100, TimeUnit.MILLISECONDS); validate(gooSink, "boom"); validate(prickleSink); }
@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();  }