public final class PagingManagerImpl extends Object implements PagingManager
Constructor and Description |
---|
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
PagingManagerImpl(PagingStoreFactory pagingSPI,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
long maxSize) |
Modifier and Type | Method and Description |
---|---|
void |
addBlockedStore(PagingStore store) |
PagingManagerImpl |
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
|
protected void |
checkMemoryRelease() |
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() |
void |
injectMonitor(FileStoreMonitor monitor) |
boolean |
isDiskFull() |
boolean |
isGlobalFull() |
boolean |
isStarted() |
boolean |
isUsingGlobalSize() |
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.
|
public PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, long maxSize)
public PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository)
public void addBlockedStore(PagingStore store)
addBlockedStore
in interface PagingManager
public void onChange()
onChange
in interface HierarchicalRepositoryChangeListener
public PagingManagerImpl addSize(int size)
PagingManager
addSize
in interface PagingManager
protected void checkMemoryRelease()
public void injectMonitor(FileStoreMonitor monitor) throws Exception
injectMonitor
in interface PagingManager
Exception
public boolean isDiskFull()
isDiskFull
in interface PagingManager
public boolean isUsingGlobalSize()
isUsingGlobalSize
in interface PagingManager
public boolean isGlobalFull()
isGlobalFull
in interface PagingManager
public void disableCleanup()
disableCleanup
in interface PagingManager
public void resumeCleanup()
resumeCleanup
in interface PagingManager
public SimpleString[] getStoreNames()
getStoreNames
in interface PagingManager
public void reloadStores() throws Exception
PagingManager
reloadStores
in interface PagingManager
Exception
public void deletePageStore(SimpleString storeName) throws Exception
deletePageStore
in interface PagingManager
Exception
public PagingStore getPageStore(SimpleString storeName) throws Exception
getPageStore
in interface PagingManager
Exception
public void addTransaction(PageTransactionInfo pageTransaction)
PagingManager
addTransaction
in interface PagingManager
public void removeTransaction(long id)
removeTransaction
in interface PagingManager
public PageTransactionInfo getTransaction(long id)
PagingManager
getTransaction
in interface PagingManager
public Map<Long,PageTransactionInfo> getTransactions()
getTransactions
in interface PagingManager
public boolean isStarted()
isStarted
in interface ActiveMQComponent
public void start() throws Exception
start
in interface ActiveMQComponent
Exception
public void stop() throws Exception
stop
in interface ActiveMQComponent
Exception
public void processReload() throws Exception
processReload
in interface PagingManager
Exception
public void unlock()
PagingManager
unlock
in interface PagingManager
PagingManager.lock()
public void lock()
PagingManager
lock
in interface PagingManager
Copyright © 2017 JBoss by Red Hat. All rights reserved.