Thread.sleep(1000);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
eventSinkServer.stop();
if (TestingEventSinkImpl.RECEIVED_EARTHQUAKES.get() != 1) {
Assert.fail("TestingEventSinkImpl should have received 1 earthquake event but received "
+ TestingEventSinkImpl.RECEIVED_EARTHQUAKES.get());
}
if (TestingEventSinkImpl.RECEIVED_FIRES.get() != 0) {