228229230231232233234235236237238
} catch (HornetQException expected) { } manager.stop(); } finally { server.stop(); }
328329330331332333334335336337338
store.start(); Assert.assertEquals(0, store.getNumberOfPages()); manager.stop(); } finally { server.stop(); }
562563564565566567568569570571572
}); Assert.assertTrue(latch.await(1, TimeUnit.SECONDS)); Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); }
632633634635636637638639640641642
{ Assert.assertEquals(i, executions.get(i).intValue()); } Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); }