@Before public void setup() throws Exception {
assumeTrue("Multicast does not seem to be working, skip!",multicastWorking);
broker=createBroker();
try {
broker.start();
broker.waitUntilStarted();
}
catch ( Exception e) {
try {
broker.stop();
}
catch ( Exception ignore) {
}
throw e;
}
}