Examples of org.hornetq.core.paging.impl.TestSupportPageStore.depage()

Class org.hornetq.core.paging.impl.TestSupportPageStore

Examples of org.hornetq.core.paging.impl.TestSupportPageStore.depage()

org.hornetq.core.paging.impl.TestSupportPageStore.depage()
Remove the first page from the Writing Queue. The file will still exist until Page.delete is called, So, case the system is reloaded the same Page will be loaded back if delete is not called. @throws Exception Note: This should still be part of the interface, even though HornetQ only uses through the

               // Wait every producer to produce at least one message
               latchStart.await();


               while (aliveProducers.get() > 0)
               {
                  Page page = storeImpl.depage();
                  if (page != null)
                  {
                     readPages.add(page);
                  }
               }

View Full Code Here

      buffers2.put(lastMessageId, lastMsg);


      Page lastPage = null;
      while (true)
      {
         Page page = storeImpl2.depage();
         if (page == null)
         {
            break;
         }

View Full Code Here

      Assert.assertEquals(0, storeImpl.getNumberOfPages());


      // Marked the store to be paged
      storeImpl.startPaging();


      storeImpl.depage();


      assertNull(storeImpl.getCurrentPage());


      storeImpl.startPaging();

View Full Code Here


               long msgsRead = 0;


               while (msgsRead < NUMBER_OF_MESSAGES)
               {
                  Page page = storeImpl.depage();
                  if (page != null)
                  {
                     page.open();
                     List<PagedMessage> messages = page.read(new NullStorageManager());

View Full Code Here


      Assert.assertEquals(1, storeImpl.getNumberOfPages());


      storeImpl.sync();


      Page page = storeImpl.depage();


      page.open();


      List<PagedMessage> msg = page.read();

View Full Code Here

      List<PagedMessage> msg = page.read();


      Assert.assertEquals(numMessages, msg.size());
      Assert.assertEquals(1, storeImpl.getNumberOfPages());


      page = storeImpl.depage();


      Assert.assertNull(page);


      Assert.assertEquals(0, storeImpl.getNumberOfPages());

View Full Code Here


      int sequence = 0;


      for (int pageNr = 0; pageNr < 2; pageNr++)
      {
         Page page = storeImpl.depage();


         page.open();


         List<PagedMessage> msg = page.read();

View Full Code Here


      ServerMessage msg = createMessage(1, storeImpl, destination, buffers.get(0));


      Assert.assertTrue(storeImpl.page(msg, true));


      Page newPage = storeImpl.depage();


      newPage.open();


      Assert.assertEquals(1, newPage.read().size());

View Full Code Here


      Assert.assertEquals(1, storeImpl.getNumberOfPages());


      Assert.assertTrue(storeImpl.isPaging());


      Assert.assertNull(storeImpl.depage());


      Assert.assertFalse(storeImpl.isPaging());


      Assert.assertFalse(storeImpl.page(msg, true));

View Full Code Here


      storeImpl.startPaging();


      Assert.assertTrue(storeImpl.page(msg, true));


      Page page = storeImpl.depage();


      page.open();


      List<PagedMessage> msgs = page.read();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.