Examples of org.hornetq.core.paging.PagingManager

 +------------+      1  +-------------+       N +------------+       N +-------+       1 +----------------+ |  {@link PostOffice} |-------> |PagingManager|-------> |{@link PagingStore} | ------> | {@link Page}  | ------> | {@link SequentialFile} |+------------+         +-------------+         +------------+         +-------+         +----------------+ |                       1 ^ |                         | |                         | |                         | 1 |        N +---------+ +--------> | Address | +---------+

@author Clebert Suconic @author Tim Fox @author

         manager.pageWrite(pgmsg, 3);
         manager.pageWrite(pgmsg, 4);


         blockOnReplication(storage, manager);


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


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


         manager.pageDeleted(dummy, 1);

View Full Code Here

                                             final Configuration configuration,
                                             final ExecutorFactory executorFactory,
                                             final HierarchicalRepository<AddressSettings> addressSettingsRepository) throws Exception
   {


      PagingManager paging = new PagingManagerImpl(new PagingStoreFactoryNIO(configuration.getPagingDirectory(),
                                                                             1000,
                                                                             null,
                                                                             executorFactory,
                                                                             false),
                                                   storageManager,
                                                   addressSettingsRepository);


      paging.start();
      return paging;
   }

View Full Code Here

         };
         PagingStoreFactory pageStoreFactory = new PagingStoreFactoryNIO(config.getPagingDirectory(), 1000l, scheduled, executorFactory, false, null);
         HierarchicalRepository<AddressSettings> addressSettingsRepository = new HierarchicalObjectRepository<AddressSettings>();
         addressSettingsRepository.setDefault(new AddressSettings());
         StorageManager sm = new NullStorageManager();
         PagingManager manager = new PagingManagerImpl(pageStoreFactory, sm, addressSettingsRepository);


         manager.start();


         SimpleString stores[] = manager.getStoreNames();


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


            if (pageStore != null)
            {
               folder = pageStore.getFolder();

View Full Code Here

            }
         };


         OperationContextImpl.setContext(ctx);


         PagingManager paging = server.getPagingManager();


         PagingStore store = paging.getPageStore(ADDRESS);


         store.sync();


         assertTrue(pageUp.await(10, TimeUnit.SECONDS));

View Full Code Here

            }
         };


         OperationContextImpl.setContext(ctx);


         PagingManager paging = server.getPagingManager();


         PagingStore store = paging.getPageStore(ADDRESS);


         store.sync();


         assertTrue(pageUp.await(10, TimeUnit.SECONDS));

View Full Code Here

            }
         };
         PagingStoreFactory pageStoreFactory = new PagingStoreFactoryNIO(config.getPagingDirectory(), 1000l, scheduled, executorFactory, true, null);
         HierarchicalRepository<AddressSettings> addressSettingsRepository = new HierarchicalObjectRepository<AddressSettings>();
         addressSettingsRepository.setDefault(new AddressSettings());
         PagingManager manager = new PagingManagerImpl(pageStoreFactory, storageManager, addressSettingsRepository);


         manager.start();


         SimpleString stores[] = manager.getStoreNames();


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


            if (pageStore != null)
            {
               folder = pageStore.getFolder();

View Full Code Here

         };
         PagingStoreFactory pageStoreFactory = new PagingStoreFactoryNIO(config.getPagingDirectory(), 1000l, scheduled, executorFactory, false, null);
         HierarchicalRepository<AddressSettings> addressSettingsRepository = new HierarchicalObjectRepository<AddressSettings>();
         addressSettingsRepository.setDefault(new AddressSettings());
         StorageManager sm = new NullStorageManager();
         PagingManager manager = new PagingManagerImpl(pageStoreFactory, sm, addressSettingsRepository);


         manager.start();


         SimpleString stores[] = manager.getStoreNames();


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


            if (pageStore != null)
            {
               folder = pageStore.getFolder();

View Full Code Here

            }
         };


         OperationContextImpl.setContext(ctx);


         PagingManager paging = server.getPagingManager();


         PagingStore store = paging.getPageStore(ADDRESS);


         store.sync();


         assertTrue(pageUp.await(10, TimeUnit.SECONDS));

View Full Code Here

            }
         };


         OperationContextImpl.setContext(ctx);


         PagingManager paging = server.getPagingManager();


         PagingStore store = paging.getPageStore(ADDRESS);


         store.sync();


         assertTrue(pageUp.await(10, TimeUnit.SECONDS));

View Full Code Here

         };
         PagingStoreFactory pageStoreFactory = new PagingStoreFactoryNIO(config.getPagingDirectory(), 1000l, scheduled, executorFactory, false, null);
         HierarchicalRepository<AddressSettings> addressSettingsRepository = new HierarchicalObjectRepository<AddressSettings>();
         addressSettingsRepository.setDefault(new AddressSettings());
         StorageManager sm = new NullStorageManager();
         PagingManager manager = new PagingManagerImpl(pageStoreFactory, sm, addressSettingsRepository);


         manager.start();


         SimpleString stores[] = manager.getStoreNames();


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


            if (pageStore != null)
            {
               folder = pageStore.getFolder();

View Full Code Here

0 1 2 3 4

TOP

Examples of org.hornetq.core.paging.PagingManager

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