Package 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	Description
PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository)
PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, long maxSize, long maxMessages, SimpleString managementAddress, ActiveMQServer server)
PagingManagerImpl(PagingStoreFactory pagingSPI, HierarchicalRepository<AddressSettings> addressSettingsRepository, SimpleString managementAddress)

Method Summary

Modifier and Type	Method	Description
void	addBlockedStore(PagingStore store)
PagingManagerImpl	addSize(int size, boolean sizeOnly)	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	checkStorage(Runnable runWhenAvailable)	Use this when you have no refernce of an address.
void	counterSnapshot()
void	deletePageStore(SimpleString storeName)
void	disableCleanup()
void	execute(Runnable run)	Execute a runnable inside the PagingManager's executor
void	forEachTransaction(BiConsumer<Long,PageTransactionInfo> transactionConsumer)
Set<PagingStore>	getBlockedSet()
long	getDiskTotalSpace()
long	getDiskUsableSpace()
long	getGlobalMessages()
long	getGlobalSize()
long	getMaxMessages()
long	getMaxSize()
PagingStore	getPageStore(SimpleString rawStoreName)	This method creates a new store if not exist.
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	isRebuildingCounters()
boolean	isStarted()
boolean	isUsingGlobalSize()
void	lock()	Lock the manager.
void	onChange()
void	processReload()
Future<Object>	rebuildCounters(Set<Long> storedLargeMessages)	Rebuilds all page counters for destinations that are paging in the background.
void	reloadStores()	Reload previously created PagingStores into memory
void	removeTransaction(long id)
void	replacePageStoreFactory(PagingStoreFactory factory)
void	resumeCleanup()
protected void	setDiskFull(boolean diskFull)
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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Methods inherited from interface org.apache.activemq.artemis.core.paging.PagingManager

addSize, addSizeOnly

Constructor Details

PagingManagerImpl

public PagingManagerImpl(PagingStoreFactory pagingSPI,
 HierarchicalRepository<AddressSettings> addressSettingsRepository,
 long maxSize,
 long maxMessages,
 SimpleString managementAddress,
 ActiveMQServer server)

PagingManagerImpl

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

PagingManagerImpl

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

Method Details

replacePageStoreFactory

public void replacePageStoreFactory(PagingStoreFactory factory)

getPagingStoreFactory

public PagingStoreFactory getPagingStoreFactory()

getMaxSize

public long getMaxSize()

Specified by:

getMaxSize in interface PagingManager

getMaxMessages

public long getMaxMessages()

Specified by:

getMaxMessages in interface PagingManager

addBlockedStore

public void addBlockedStore(PagingStore store)

Specified by:

addBlockedStore in interface PagingManager

getBlockedSet

public Set<PagingStore> getBlockedSet()

onChange

public void onChange()

Specified by:

onChange in interface HierarchicalRepositoryChangeListener

addSize

public PagingManagerImpl addSize(int size,
 boolean sizeOnly)

Description copied from interface: PagingManager

Add size at the global count level. If sizeOnly = true, only the size portion is updated. If false both the counter for bytes and number of messages is updated.

Specified by:

addSize in interface PagingManager

getGlobalSize

public long getGlobalSize()

Specified by:

getGlobalSize in interface PagingManager

getGlobalMessages

public long getGlobalMessages()

Specified by:

getGlobalMessages in interface PagingManager

checkMemoryRelease

protected void checkMemoryRelease()

execute

public void execute(Runnable run)

Description copied from interface: PagingManager

Execute a runnable inside the PagingManager's executor

Specified by:

execute in interface PagingManager

injectMonitor

public void injectMonitor(FileStoreMonitor monitor)
                   throws Exception

Specified by:

injectMonitor in interface PagingManager

Throws:

Exception

setDiskFull

protected void setDiskFull(boolean diskFull)

isDiskFull

public boolean isDiskFull()

Specified by:

isDiskFull in interface PagingManager

getDiskUsableSpace

public long getDiskUsableSpace()

Specified by:

getDiskUsableSpace in interface PagingManager

getDiskTotalSpace

public long getDiskTotalSpace()

Specified by:

getDiskTotalSpace 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

checkStorage

public void checkStorage(Runnable runWhenAvailable)

Description copied from interface: PagingManager

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

Specified by:

checkStorage 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 rawStoreName)
                         throws Exception

This method creates a new store if not exist.

Specified by:

getPageStore in interface PagingManager

Returns:

the PageStore associated with the address; a new page store is created if necessary

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

isRebuildingCounters

public boolean isRebuildingCounters()

Specified by:

isRebuildingCounters in interface PagingManager

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

counterSnapshot

public void counterSnapshot()

Specified by:

counterSnapshot in interface PagingManager

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

forEachTransaction

public void forEachTransaction(BiConsumer<Long,PageTransactionInfo> transactionConsumer)

Specified by:

forEachTransaction in interface PagingManager

rebuildCounters

public Future<Object> rebuildCounters(Set<Long> storedLargeMessages)

Description copied from interface: PagingManager

Rebuilds all page counters for destinations that are paging in the background.

Specified by:

rebuildCounters in interface PagingManager