controller.start();
latch.await(30000, TimeUnit.MILLISECONDS);
// clean up
controller.stop();
connection.disconnect();
Assert.assertEquals(allocated, MAX_PARTICIPANTS);
Assert.assertEquals(started, MAX_PARTICIPANTS);
Assert.assertEquals(stopped, MAX_PARTICIPANTS);