208209210211212213214215216217218
Assert.assertTrue(storeImpl.page(msg, new RoutingContextImpl(null))); Assert.assertEquals(1, storeImpl.getNumberOfPages()); storeImpl.sync(); storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName, null, 100, createMockManager(),
274275276277278279280281282283284
Assert.assertTrue(storeImpl.page(msg, new RoutingContextImpl(null))); } Assert.assertEquals(1, storeImpl.getNumberOfPages()); storeImpl.sync(); Page page = storeImpl.depage(); page.open();
355356357358359360361362363364365
Assert.assertTrue(storeImpl.page(msg, new RoutingContextImpl(null))); } Assert.assertEquals(2, storeImpl.getNumberOfPages()); storeImpl.sync(); int sequence = 0; for (int pageNr = 0; pageNr < 2; pageNr++) {
210211212213214215216217218219220
276277278279280281282283284285286
357358359360361362363364365366367
211212213214215216217218219220221
277278279280281282283284285286287
358359360361362363364365366367368
194195196197198199200201202203204