Examples of org.hornetq.core.paging.PagingStore

org.hornetq.core.paging.PagingStore

The implementation will take care of details such as PageSize.

The producers will write directly to PagingStore and that will decide what Page file should be used based on configured size
@see PagingManager @author Clebert Suconic

         ClientProducer producer = session.createProducer(PageCrashTest.ADDRESS);


         ClientMessage message = session.createMessage(true);
         message.getBodyBuffer().writeBytes(new byte[1024]);


         PagingStore store = server.getPostOffice().getPagingManager().getPageStore(PageCrashTest.ADDRESS);


         int messages = 0;
         while (!store.isPaging())
         {
            producer.send(message);
            messages++;
            if (transacted && messages % 100 == 0)
            {

View Full Code Here

      SequentialFileFactory factory = new FakeSequentialFileFactory();


      AddressSettings addressSettings = new AddressSettings();
      addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);


      PagingStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                  createMockManager(),
                                                  createStorageManagerMock(),
                                                  createPostOfficeMock(),
                                                  factory,
                                                  null,
                                                  PagingStoreImplTest.destinationTestName,
                                                  addressSettings,
                                                  executor,
                                                  true);


      storeImpl.start();


      // this is not supposed to throw an exception.
      // As you could have start being called twice as Stores are dynamically
      // created, on a multi-thread environment
      storeImpl.start();


      storeImpl.stop();


   }

View Full Code Here


         SimpleString[] stores = manager.getStoreNames();


         for (SimpleString store : stores)
         {
            PagingStore pgStore = manager.getPageStore(store);
            String folder = null;


            if (pgStore != null)
            {
               folder = pgStore.getFolder();
            }
            System.out.println("####################################################################################################");
            System.out.println("Exploring store " + store + " folder = " + folder);
            int pgid = (int) pgStore.getFirstPage();
            for (int pg = 0; pg < pgStore.getNumberOfPages(); pg++)
            {
               System.out.println("*******   Page " + pgid);
               Page page = pgStore.createPage(pgid);
               page.open();
               List<PagedMessage> msgs = page.read(sm);
               page.close();


               int msgID = 0;

View Full Code Here

      }
   }


   public void requestProducerCredits(final SimpleString address, final int credits) throws Exception
   {
      PagingStore store = server.getPagingManager().getPageStore(address);


      if (!store.checkMemory(new Runnable()
      {
         public void run()
         {
            callback.sendProducerCreditsMessage(credits, address);
         }

View Full Code Here

      }
   }


   public void requestProducerCredits(final SimpleString address, final int credits) throws Exception
   {
      PagingStore store = postOffice.getPagingManager().getPageStore(address);


      store.executeRunnableWhenMemoryAvailable(new Runnable()
      {
         public void run()
         {
            callback.sendProducerCreditsMessage(credits, address);
         }

View Full Code Here

   public void deletePageStore(final SimpleString storeName) throws Exception
   {
      syncLock.readLock().lock();
      try
      {
         PagingStore store = stores.remove(storeName);
         if (store != null)
         {
            store.stop();
         }
      }
      finally
      {
         syncLock.readLock().unlock();

View Full Code Here

   }


   /** stores is a ConcurrentHashMap, so we don't need to synchronize this method */
   public PagingStore getPageStore(final SimpleString storeName) throws Exception
   {
      PagingStore store = stores.get(storeName);


      if (store != null)
      {
         return store;
      }

View Full Code Here


   private PagingStore newStore(final SimpleString address) throws Exception
   {
      syncLock.readLock().lock();
      try {
         PagingStore store = stores.get(address);
         if (store == null)
         {
            store = pagingStoreFactory.newStore(address, addressSettingsRepository.getMatch(address.toString()));
            store.start();
            if (!cleanupEnabled)
            {
               store.disableCleanup();
            }
            stores.put(address, store);
         }
         return store;
      }

View Full Code Here

      }
   }


   public void requestProducerCredits(final SimpleString address, final int credits) throws Exception
   {
      PagingStore store = postOffice.getPagingManager().getPageStore(address);


      store.executeRunnableWhenMemoryAvailable(new Runnable()
      {
         public void run()
         {
            callback.sendProducerCreditsMessage(credits, address);
         }

View Full Code Here

         PagingManager pagingManager = createPageManager(server.getStorageManager(),
                                                         server.getConfiguration(),
                                                         server.getExecutorFactory(),
                                                         server.getAddressSettingsRepository());


         PagingStore store = pagingManager.getPageStore(dummy);
         store.start();
         Assert.assertEquals(5, store.getNumberOfPages());
         store.stop();


         manager.pageDeleted(dummy, 1);
         manager.pageDeleted(dummy, 2);
         manager.pageDeleted(dummy, 3);
         manager.pageDeleted(dummy, 4);
         manager.pageDeleted(dummy, 5);
         manager.pageDeleted(dummy, 6);


         blockOnReplication(storage, manager);


         ServerMessageImpl serverMsg = new ServerMessageImpl();
         serverMsg.setMessageID(500);
         serverMsg.setAddress(new SimpleString("tttt"));


         HornetQBuffer buffer = HornetQBuffers.dynamicBuffer(100);
         serverMsg.encodeHeadersAndProperties(buffer);


         manager.largeMessageBegin(500);


         manager.largeMessageWrite(500, new byte[1024]);


         manager.largeMessageDelete(500);


         blockOnReplication(storage, manager);


         store.start();


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


         manager.stop();
      }
      finally
      {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.hornetq.core.paging.PagingStore

org.hornetq.core.management.impl.AddressControlImpl

org.hornetq.core.paging.impl.PagingManagerImpl

org.hornetq.core.paging.impl.PagingStoreFactoryNIO

org.hornetq.core.persistence.impl.journal.JournalStorageManager

org.hornetq.core.persistence.impl.journal.XmlDataExporter

org.hornetq.core.postoffice.impl.PostOfficeImpl

org.hornetq.core.server.impl.HornetQServerImpl

org.hornetq.core.server.impl.PostOfficeJournalLoader

org.hornetq.core.server.impl.ServerInfo

org.hornetq.core.server.impl.ServerSessionImpl

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.