public class PagingStoreFactoryNIO extends Object implements PagingStoreFactory
Modifier and Type | Field and Description |
---|---|
static String |
ADDRESS_FILE |
Constructor and Description |
---|
PagingStoreFactoryNIO(StorageManager storageManager,
File directory,
long syncTimeout,
ScheduledExecutorService scheduledExecutor,
ExecutorFactory executorFactory,
boolean syncNonTransactional,
IOCriticalErrorListener critialErrorListener) |
Modifier and Type | Method and Description |
---|---|
IOCriticalErrorListener |
getCritialErrorListener() |
File |
getDirectory() |
ExecutorFactory |
getExecutorFactory() |
PagingManager |
getPagingManager() |
ScheduledExecutorService |
getScheduledExecutor() |
StorageManager |
getStorageManager() |
long |
getSyncTimeout() |
void |
injectMonitor(FileStoreMonitor monitor) |
boolean |
isSyncNonTransactional() |
PageCursorProvider |
newCursorProvider(PagingStore store,
StorageManager storageManager,
AddressSettings addressSettings,
ArtemisExecutor executor) |
Executor |
newExecutor() |
SequentialFileFactory |
newFileFactory(SimpleString address) |
protected SequentialFileFactory |
newFileFactory(String directoryName) |
PagingStore |
newStore(SimpleString address,
AddressSettings settings) |
List<PagingStore> |
reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository) |
void |
removeFileFactory(SequentialFileFactory fileFactory) |
void |
setPagingManager(PagingManager pagingManager) |
void |
stop() |
public static final String ADDRESS_FILE
public PagingStoreFactoryNIO(StorageManager storageManager, File directory, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener critialErrorListener)
public File getDirectory()
public ExecutorFactory getExecutorFactory()
public boolean isSyncNonTransactional()
public PagingManager getPagingManager()
public long getSyncTimeout()
public StorageManager getStorageManager()
public IOCriticalErrorListener getCritialErrorListener()
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
protected SequentialFileFactory newFileFactory(String directoryName)
Copyright © 2020 JBoss by Red Hat. All rights reserved.