org.hornetq.core.paging.impl

Class PagingManagerImpl

java.lang.Object

org.hornetq.core.paging.impl.PagingManagerImpl

All Implemented Interfaces:

PagingManager, HornetQComponent, HierarchicalRepositoryChangeListener

public class PagingManagerImpl
extends Object
implements PagingManager

Author:

Clebert Suconic, Tim Fox,

Constructor Summary

Constructors

Constructor and Description
PagingManagerImpl(PagingStoreFactory pagingSPI, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTransaction(PageTransactionInfo pageTransaction) Point to inform/restoring Transactions used when the messages were added into paging
void	deletePageStore(SimpleString storeName)
PagingStore	getPageStore(SimpleString storeName) stores is a ConcurrentHashMap, so we don't need to synchronize this method
protected PagingStoreFactory	getStoreFactory()
SimpleString[]	getStoreNames()
PageTransactionInfo	getTransaction(long id) Point to inform/restoring Transactions used when the messages were added into paging
Map<Long,PageTransactionInfo>	getTransactions()
boolean	isStarted()
protected PagingStore	newStore(SimpleString address)
void	onChange()
void	processReload()
void	reaplySettings()
void	reloadStores() Reload previously created PagingStores into memory
void	removeTransaction(long id)
void	setPostOffice(PostOffice postOffice) this will be set by the postOffice itself.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

PagingManagerImpl

public PagingManagerImpl(PagingStoreFactory pagingSPI,
                 StorageManager storageManager,
                 HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Detail

onChange

public void onChange()

Specified by:

onChange in interface HierarchicalRepositoryChangeListener

reaplySettings

public void reaplySettings()

getStoreNames

public SimpleString[] getStoreNames()

Specified by:

getStoreNames in interface PagingManager

reloadStores

public void reloadStores()
                  throws Exception

Description copied from interface: PagingManager

Reload previously created PagingStores into memory

Specified by:

reloadStores in interface PagingManager

Throws:

Exception

deletePageStore

public void deletePageStore(SimpleString storeName)
                     throws Exception

Specified by:

deletePageStore in interface PagingManager

Throws:

Exception

getPageStore

public PagingStore getPageStore(SimpleString storeName)
                         throws Exception

stores is a ConcurrentHashMap, so we don't need to synchronize this method

Specified by:

getPageStore in interface PagingManager

Throws:

Exception

setPostOffice

public void setPostOffice(PostOffice postOffice)

this will be set by the postOffice itself. There is no way to set this on the constructor as the PagingManager is constructed before the postOffice. (There is a one-to-one relationship here)

Specified by:

setPostOffice in interface PagingManager

addTransaction

public void addTransaction(PageTransactionInfo pageTransaction)

Description copied from interface: PagingManager

Point to inform/restoring Transactions used when the messages were added into paging

Specified by:

addTransaction in interface PagingManager

removeTransaction

public void removeTransaction(long id)

Specified by:

removeTransaction in interface PagingManager

getTransaction

public PageTransactionInfo getTransaction(long id)

Description copied from interface: PagingManager

Point to inform/restoring Transactions used when the messages were added into paging

Specified by:

getTransaction in interface PagingManager

getTransactions

public Map<Long,PageTransactionInfo> getTransactions()

Specified by:

getTransactions in interface PagingManager

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

processReload

public void processReload()
                   throws Exception

Specified by:

processReload in interface PagingManager

Throws:

Exception

newStore

protected PagingStore newStore(SimpleString address)

getStoreFactory

protected PagingStoreFactory getStoreFactory()