org.hornetq.core.paging

Interface PagingManager

All Superinterfaces:

HierarchicalRepositoryChangeListener, HornetQComponent

All Known Implementing Classes:

PagingManagerImpl

public interface PagingManager
extends HornetQComponent, HierarchicalRepositoryChangeListener

 

 +------------+      1  +-------------+       N +------------+       N +-------+       1 +----------------+
 | PostOffice |-------> |PagingManager|-------> |PagingStore | ------> | Page  | ------> | SequentialFile |
 +------------+         +-------------+         +------------+         +-------+         +----------------+
 |                       1 ^
 |                         |
 |                         |
 |                         | 1
 |        N +---------+   /
 +--------> | Address |
 +---------+
 

Author:

Clebert Suconic, Tim Fox,

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 address) Returns the PageStore associated with the address.
SimpleString[]	getStoreNames()
PageTransactionInfo	getTransaction(long transactionID) Point to inform/restoring Transactions used when the messages were added into paging
Map<Long,PageTransactionInfo>	getTransactions()
void	lock() Lock the manager.
void	processReload()
void	reloadStores() Reload previously created PagingStores into memory
void	removeTransaction(long transactionID)
void	resumeCleanup()
void	unlock() Unlock the manager.

Methods inherited from interface org.hornetq.core.server.HornetQComponent

isStarted, start, stop

Methods inherited from interface org.hornetq.core.settings.HierarchicalRepositoryChangeListener

onChange

Method Detail

getPageStore

PagingStore getPageStore(SimpleString address)
                         throws Exception

Returns the PageStore associated with the address. A new page store is created if necessary.

Throws:

Exception

addTransaction

void addTransaction(PageTransactionInfo pageTransaction)

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

getTransaction

PageTransactionInfo getTransaction(long transactionID)

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

removeTransaction

void removeTransaction(long transactionID)

Parameters:

transactionID -

getTransactions

Map<Long,PageTransactionInfo> getTransactions()

reloadStores

void reloadStores()
                  throws Exception

Reload previously created PagingStores into memory

Throws:

Exception

getStoreNames

SimpleString[] getStoreNames()

deletePageStore

void deletePageStore(SimpleString storeName)
                     throws Exception

Throws:

Exception

processReload

void processReload()
                   throws Exception

Throws:

Exception

disableCleanup

void disableCleanup()

resumeCleanup

void resumeCleanup()

lock

void lock()

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

unlock

void unlock()

Unlock the manager.

See Also:

lock()