150151152153154155156157158159160
for (int i = 0; i < 100; i++) { cacheID.addToCache(RandomUtil.randomBytes(), null); } journal.stop(); mapDups.clear(); journal = new JournalStorageManager(configuration, factory); journal.start();
178179180181182183184185186187188
{ if (journal != null) { try { journal.stop(); } catch (Throwable ignored) { } }
101102103104105106107108109110111
Map<Long, Queue> queues = new HashMap<Long, Queue>(); journal.loadMessageJournal(postOffice, null, null, queues, null, null); journal.stop(); deleteDirectory(testdir); journal.start();
122123124125126127128129130131132
finally { try { journal.stop(); } catch (Exception ex) { RestartSMTest.log.warn(ex.getMessage(), ex); }
121122123124125126127128129130131
for (int i = 0; i < 100; i++) { cacheID.addToCache(RandomUtil.randomBytes(), null); } journal.stop(); journal = new JournalStorageManager(configuration, factory); journal.start(); journal.loadBindingJournal(new ArrayList<QueueBindingInfo>(), new ArrayList<GroupingInfo>());
148149150151152153154155156157158
175176177178179180181182183184185
123124125126127128129130131132133
152153154155156157158159160161162
181182183184185186187188189190191