public class PagingStoreFactoryDatabase extends Object implements PagingStoreFactory
Modifier and Type | Field and Description |
---|---|
protected StorageManager |
storageManager |
protected boolean |
syncNonTransactional |
Constructor and Description |
---|
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener) |
PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf,
StorageManager storageManager,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener criticalErrorListener,
boolean readWholePage) |
Modifier and Type | Method and Description |
---|---|
ScheduledExecutorService |
getScheduledExecutor() |
void |
injectMonitor(FileStoreMonitor monitor) |
PageCursorProvider |
newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
Executor |
newExecutor() |
SequentialFileFactory |
newFileFactory(SimpleString address) |
PagingStore |
newStore(SimpleString address,
AddressSettings settings) |
List<PagingStore> |
reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
void |
removeFileFactory(SequentialFileFactory fileFactory) |
void |
setPagingManager(PagingManager pagingManager) |
void |
start() |
void |
stop() |
protected final boolean syncNonTransactional
protected final StorageManager storageManager
public PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf, StorageManager storageManager, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener criticalErrorListener) throws Exception
Exception
public PagingStoreFactoryDatabase(DatabaseStorageConfiguration dbConf, StorageManager storageManager, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener criticalErrorListener, boolean readWholePage) throws Exception
Exception
public ScheduledExecutorService getScheduledExecutor()
getScheduledExecutor
in interface PagingStoreFactory
public Executor newExecutor()
newExecutor
in interface PagingStoreFactory
public void stop()
stop
in interface PagingStoreFactory
public void injectMonitor(FileStoreMonitor monitor) throws Exception
injectMonitor
in interface PagingStoreFactory
Exception
public PageCursorProvider newCursorProvider(PagingStore store, StorageManager storageManager, AddressSettings addressSettings, ArtemisExecutor executor)
newCursorProvider
in interface PagingStoreFactory
public PagingStore newStore(SimpleString address, AddressSettings settings)
newStore
in interface PagingStoreFactory
public SequentialFileFactory newFileFactory(SimpleString address) throws Exception
newFileFactory
in interface PagingStoreFactory
Exception
public void removeFileFactory(SequentialFileFactory fileFactory) throws Exception
removeFileFactory
in interface PagingStoreFactory
Exception
public void setPagingManager(PagingManager pagingManager)
setPagingManager
in interface PagingStoreFactory
public List<PagingStore> reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) throws Exception
reloadStores
in interface PagingStoreFactory
Exception
Copyright © 2021 JBoss by Red Hat. All rights reserved.