org.hornetq.core.paging.impl

Class PagingManagerImpl

java.lang.Object

org.hornetq.core.paging.impl.PagingManagerImpl

All Implemented Interfaces:

PagingManager, HornetQComponent, HierarchicalRepositoryChangeListener

public final class PagingManagerImpl
extends Object
implements PagingManager

Author:

Clebert Suconic, Tim Fox,

Constructor Summary

Constructors

Constructor and Description
PagingManagerImpl(PagingStoreFactory pagingSPI, 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)
void	disableCleanup()
PagingStore	getPageStore(SimpleString storeName) stores is a ConcurrentHashMap, so we don't need to synchronize this method
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()
void	lock() Lock the manager.
void	onChange()
void	processReload()
void	reloadStores() Reload previously created PagingStores into memory
void	removeTransaction(long id)
void	resumeCleanup()
void	start()
void	stop()
void	unlock() Unlock the manager.

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,
                 HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Detail

onChange

public void onChange()

Specified by:

onChange in interface HierarchicalRepositoryChangeListener

disableCleanup

public void disableCleanup()

Specified by:

disableCleanup in interface PagingManager

resumeCleanup

public void resumeCleanup()

Specified by:

resumeCleanup in interface PagingManager

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

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

unlock

public void unlock()

Description copied from interface: PagingManager

Unlock the manager.

Specified by:

unlock in interface PagingManager

See Also:

PagingManager.lock()

lock

public void lock()

Description copied from interface: PagingManager

Lock the manager. This method should not be called during normal PagingManager usage.

Specified by:

lock in interface PagingManager