Package org.apache.activemq.artemis.core.paging

Interface PagingStoreFactory

All Known Implementing Classes:

PagingStoreFactoryDatabase, PagingStoreFactoryNIO

public interface PagingStoreFactory

The integration point between the PagingManger and the File System (aka SequentialFiles)

Method Summary

Modifier and Type	Method	Description
default ScheduledExecutorService	getScheduledExecutor()
void	injectMonitor(FileStoreMonitor monitor)
PageCursorProvider	newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor)
default Executor	newExecutor()
SequentialFileFactory	newFileFactory(SimpleString address)
PagingStore	newStore(SimpleString address, AddressSettings addressSettings)
List<PagingStore>	reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository)
void	removeFileFactory(SequentialFileFactory fileFactory)
void	setPagingManager(PagingManager manager)
void	stop()

Method Details

newStore

PagingStore newStore(SimpleString address,
 AddressSettings addressSettings)

newCursorProvider

PageCursorProvider newCursorProvider(PagingStore store,
 StorageManager storageManager,
 AddressSettings addressSettings,
 ArtemisExecutor executor)

stop

void stop()
   throws InterruptedException

Throws:

InterruptedException

setPagingManager

void setPagingManager(PagingManager manager)

reloadStores

List<PagingStore> reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository)
                        throws Exception

Throws:

Exception

newFileFactory

SequentialFileFactory newFileFactory(SimpleString address)
                              throws Exception

Throws:

Exception

removeFileFactory

void removeFileFactory(SequentialFileFactory fileFactory)
                throws Exception

Throws:

Exception

injectMonitor

void injectMonitor(FileStoreMonitor monitor)
            throws Exception

Throws:

Exception

getScheduledExecutor

default ScheduledExecutorService getScheduledExecutor()

newExecutor

default Executor newExecutor()