public class PagingManagerImpl extends Object implements PagingManager
Constructor and Description |
---|
PagingManagerImpl(PagingStoreFactory pagingSPI,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
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 storeName)
stores is a ConcurrentHashMap, so we don't need to synchronize this method
|
protected PagingStoreFactory |
getStoreFactory() |
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() |
protected PagingStore |
newStore(SimpleString address) |
void |
onChange() |
void |
processReload() |
void |
reaplySettings() |
void |
reloadStores()
Reload previously created PagingStores into memory
|
void |
removeTransaction(long id) |
void |
setPostOffice(PostOffice postOffice)
this will be set by the postOffice itself.
|
void |
start() |
void |
stop() |
public PagingManagerImpl(PagingStoreFactory pagingSPI, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository)
public void onChange()
onChange
in interface HierarchicalRepositoryChangeListener
public void reaplySettings()
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 setPostOffice(PostOffice postOffice)
setPostOffice
in interface PagingManager
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 HornetQComponent
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public void processReload() throws Exception
processReload
in interface PagingManager
Exception
protected PagingStore newStore(SimpleString address)
protected PagingStoreFactory getStoreFactory()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.