org.apache.activemq.artemis.core.paging.impl

Class PagingManagerImpl

java.lang.Object

org.apache.activemq.artemis.core.paging.impl.PagingManagerImpl

All Implemented Interfaces:

PagingManager, ActiveMQComponent, HierarchicalRepositoryChangeListener

public final class PagingManagerImpl
extends Object
implements PagingManager

Constructor Summary

Constructors

Constructor and Description
PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository)
PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, long maxSize)

Method Summary

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
void	checkMemory(Runnable runWhenAvailable) Use this when you have no refernce of an address.
protected void	checkMemoryRelease()
void	debug()
void	deletePageStore(SimpleString storeName)
void	disableCleanup()
long	getGlobalSize()
PagingStore	getPageStore(SimpleString storeName) stores is a ConcurrentHashMap, so we don't need to synchronize this method
PagingStoreFactory	getPagingStoreFactory()
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	replacePageStoreFactory(PagingStoreFactory factory)
void	resumeCleanup()
void	start()
void	stop()
void	unlock() Unlock the manager.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PagingManagerImpl

public PagingManagerImpl(PagingStoreFactory pagingSPI,
                         HierarchicalRepository<AddressSettings> addressSettingsRepository,
                         long maxSize)

PagingManagerImpl

public PagingManagerImpl(PagingStoreFactory pagingSPI,
                         HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Detail

replacePageStoreFactory

public void replacePageStoreFactory(PagingStoreFactory factory)

getPagingStoreFactory

public PagingStoreFactory getPagingStoreFactory()

addBlockedStore

public void addBlockedStore(PagingStore store)

Specified by:

addBlockedStore in interface PagingManager

onChange

public void onChange()

Specified by:

onChange in interface HierarchicalRepositoryChangeListener

addSize

public PagingManagerImpl addSize(int size)

Description copied from interface: PagingManager

Add size at the global count level. if totalSize > globalMaxSize it will return true

Specified by:

addSize in interface PagingManager

getGlobalSize

public long getGlobalSize()

Specified by:

getGlobalSize in interface PagingManager

checkMemoryRelease

protected void checkMemoryRelease()

injectMonitor

public void injectMonitor(FileStoreMonitor monitor)
                   throws Exception

Specified by:

injectMonitor in interface PagingManager

Throws:

Exception

isDiskFull

public boolean isDiskFull()

Specified by:

isDiskFull in interface PagingManager

isUsingGlobalSize

public boolean isUsingGlobalSize()

Specified by:

isUsingGlobalSize in interface PagingManager

checkMemory

public void checkMemory(Runnable runWhenAvailable)

Description copied from interface: PagingManager

Use this when you have no refernce of an address. (anonymous AMQP Producers for example)

Specified by:

checkMemory in interface PagingManager

isGlobalFull

public boolean isGlobalFull()

Specified by:

isGlobalFull in interface PagingManager

disableCleanup

public void disableCleanup()

Specified by:

disableCleanup in interface PagingManager

resumeCleanup

public void resumeCleanup()

Specified by:

resumeCleanup in interface PagingManager

getStoreNames

public SimpleString[] getStoreNames()

Specified by:

getStoreNames in interface PagingManager

reloadStores

public void reloadStores()
                  throws Exception

Description copied from interface: PagingManager

Reload previously created PagingStores into memory

Specified by:

reloadStores in interface PagingManager

Throws:

Exception

deletePageStore

public void deletePageStore(SimpleString storeName)
                     throws Exception

Specified by:

deletePageStore in interface PagingManager

Throws:

Exception

getPageStore

public PagingStore getPageStore(SimpleString storeName)
                         throws Exception

stores is a ConcurrentHashMap, so we don't need to synchronize this method

Specified by:

getPageStore in interface PagingManager

Throws:

Exception

addTransaction

public void addTransaction(PageTransactionInfo pageTransaction)

Description copied from interface: PagingManager

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

Specified by:

addTransaction in interface PagingManager

removeTransaction

public void removeTransaction(long id)

Specified by:

removeTransaction in interface PagingManager

getTransaction

public PageTransactionInfo getTransaction(long id)

Description copied from interface: PagingManager

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

Specified by:

getTransaction in interface PagingManager

getTransactions

public Map<Long,PageTransactionInfo> getTransactions()

Specified by:

getTransactions in interface PagingManager

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

debug

public void debug()

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

processReload

public void processReload()
                   throws Exception

Specified by:

processReload in interface PagingManager

Throws:

Exception

unlock

public void unlock()

Description copied from interface: PagingManager

Unlock the manager.

Specified by:

unlock in interface PagingManager

See Also:

PagingManager.lock()

lock

public void lock()

Description copied from interface: PagingManager

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

Specified by:

lock in interface PagingManager