RequestsBeingExecuted { public int events() { return events.events(); } RequestsBeingExecuted(@Qualifier("microserverEventBus") EventBus bus);  RequestsBeingExecuted(EventBus bus, String type); int events(); int size(); @Override String toString();  }
@Test public void oneEvent() { bus.post(RequestEvents.start("data", "100")); assertThat(requests.events(), is(1)); }
@Test public void twoEvents() { bus.post(RequestEvents.start("data", "100")); bus.post(RequestEvents.start("data", "120")); assertThat(requests.events(), is(2)); }
@Test public void twoIdenticalEvents() { bus.post(RequestEvents.start("data", "100")); bus.post(RequestEvents.start("data", "100")); assertThat(requests.events(), is(2)); }