public interface PagingManager extends ActiveMQComponent, HierarchicalRepositoryChangeListener
+--------------+ 1 +----------------+ N +--------------+ N +--------+ 1 +-------------------+ |PostOffice
|-------> |PagingManager
|-------> |PagingStore
| ------> |Page
| ------> |SequentialFile
| +--------------+ +----------------+ +--------------+ +--------+ +-------------------+ | 1 ^ | | | | | | 1 | N +----------+ +------------> |Address
| +----------+
Modifier and Type | Method and Description |
---|---|
void |
addBlockedStore(PagingStore store) |
PagingManager |
addSize(int size)
Add size at the global count level.
|
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 |
injectMonitor(FileStoreMonitor monitor) |
boolean |
isDiskFull() |
boolean |
isGlobalFull() |
boolean |
isUsingGlobalSize() |
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.
|
isStarted, start, stop
onChange
PagingStore getPageStore(SimpleString address) throws Exception
Exception
void addTransaction(PageTransactionInfo pageTransaction)
PageTransactionInfo getTransaction(long transactionID)
void removeTransaction(long transactionID)
transactionID
- Map<Long,PageTransactionInfo> getTransactions()
void reloadStores() throws Exception
Exception
SimpleString[] getStoreNames()
void deletePageStore(SimpleString storeName) throws Exception
Exception
void disableCleanup()
void resumeCleanup()
void addBlockedStore(PagingStore store)
void injectMonitor(FileStoreMonitor monitor) throws Exception
Exception
void lock()
void unlock()
lock()
PagingManager addSize(int size)
boolean isUsingGlobalSize()
boolean isGlobalFull()
boolean isDiskFull()
Copyright © 2017 JBoss by Red Hat. All rights reserved.