org.hornetq.core.paging.impl

Class PagingStoreFactoryNIO

java.lang.Object

org.hornetq.core.paging.impl.PagingStoreFactoryNIO

All Implemented Interfaces:

PagingStoreFactory

public class PagingStoreFactoryNIO
extends Object
implements PagingStoreFactory

Integration point between Paging and NIO

Author:

Clebert Suconic

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	syncNonTransactional

Constructor Summary

Constructors

Constructor and Description
PagingStoreFactoryNIO(String directory, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional)
PagingStoreFactoryNIO(String directory, long syncTimeout, ScheduledExecutorService scheduledExecutor, ExecutorFactory executorFactory, boolean syncNonTransactional, IOCriticalErrorListener critialErrorListener)

Method Summary

Methods

Modifier and Type	Method and Description
protected ExecutorFactory	getExecutorFactory()
protected PagingManager	getPagingManager()
protected PostOffice	getPostOffice()
protected StorageManager	getStorageManager()
SequentialFileFactory	newFileFactory(SimpleString address)
protected SequentialFileFactory	newFileFactory(String directoryName)
PagingStore	newStore(SimpleString address, AddressSettings settings)
List<PagingStore>	reloadStores(HierarchicalRepository<AddressSettings> addressSettingsRepository)
void	setPagingManager(PagingManager pagingManager)
void	setPostOffice(PostOffice postOffice)
void	setStorageManager(StorageManager storageManager)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

syncNonTransactional

protected final boolean syncNonTransactional

Constructor Detail

PagingStoreFactoryNIO

public PagingStoreFactoryNIO(String directory,
                     long syncTimeout,
                     ScheduledExecutorService scheduledExecutor,
                     ExecutorFactory executorFactory,
                     boolean syncNonTransactional)

PagingStoreFactoryNIO

public PagingStoreFactoryNIO(String directory,
                     long syncTimeout,
                     ScheduledExecutorService scheduledExecutor,
                     ExecutorFactory executorFactory,
                     boolean syncNonTransactional,
                     IOCriticalErrorListener critialErrorListener)

Method Detail

stop

public void stop()

Specified by:

stop in interface PagingStoreFactory

newStore

public PagingStore newStore(SimpleString address,
                   AddressSettings settings)

Specified by:

newStore in interface PagingStoreFactory

newFileFactory

public SequentialFileFactory newFileFactory(SimpleString address)
                                     throws Exception

Specified by:

newFileFactory in interface PagingStoreFactory

Throws:

Exception

setPagingManager

public void setPagingManager(PagingManager pagingManager)

Specified by:

setPagingManager in interface PagingStoreFactory

setStorageManager

public void setStorageManager(StorageManager storageManager)

Specified by:

setStorageManager in interface PagingStoreFactory

setPostOffice

public void setPostOffice(PostOffice postOffice)

Specified by:

setPostOffice in interface PagingStoreFactory

reloadStores

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

Specified by:

reloadStores in interface PagingStoreFactory

Throws:

Exception

newFileFactory

protected SequentialFileFactory newFileFactory(String directoryName)

getPagingManager

protected PagingManager getPagingManager()

getStorageManager

protected StorageManager getStorageManager()

getPostOffice

protected PostOffice getPostOffice()

getExecutorFactory

protected ExecutorFactory getExecutorFactory()