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)
PagingStore	getPageStore(SimpleString address) To return 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	processReload()
void	reloadStores() Reload previously created PagingStores into memory
void	removeTransaction(long transactionID)
void	setPostOffice(PostOffice postOffice) An injection point for the PostOffice to inject itself

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

To return the PageStore associated with the address

Throws:

Exception

setPostOffice

void setPostOffice(PostOffice postOffice)

An injection point for the PostOffice to inject itself

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