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(); }
114115116117118119120121122123124
try { ReplicationManagerImpl manager = new ReplicationManagerImpl((ClientSessionFactoryInternal) locator.createSessionFactory(), factory); manager.start(); manager.stop(); } finally { server.stop(); }
154155156157158159160161162163164
} manager.compareJournals(new JournalLoadInformation[] { new JournalLoadInformation(), new JournalLoadInformation() }); manager.stop(); } finally { server.stop(); }
228229230231232233234235236237238
} catch (HornetQException expected) { } manager.stop(); } finally { server.stop(); }
328329330331332333334335336337338
store.start(); Assert.assertEquals(0, store.getNumberOfPages()); manager.stop(); } finally { server.stop(); }