org.apache.activemq.artemis.core.server.files

Class FileStoreMonitor

java.lang.Object

org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

org.apache.activemq.artemis.core.server.files.FileStoreMonitor

All Implemented Interfaces:

Runnable, org.apache.activemq.artemis.core.server.ActiveMQComponent

public class FileStoreMonitor
extends org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

This will keep a list of fileStores. It will make a comparison on all file stores registered. if any is over the limit, all Callbacks will be called with over. For instance: if Large Messages folder is registered on a different folder and it's over capacity, the whole system will be waiting it to be released.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FileStoreMonitor.Callback

Constructor Summary

Constructors

Constructor and Description
FileStoreMonitor(ScheduledExecutorService scheduledExecutorService, Executor executor, long checkPeriod, TimeUnit timeUnit, double maxUsage)

Method Summary

Modifier and Type	Method and Description
FileStoreMonitor	addCallback(FileStoreMonitor.Callback callback)
FileStoreMonitor	addStore(File file)
FileStoreMonitor	addStore(FileStore store)
protected double	calculateUsage(FileStore store)
double	getMaxUsage()
void	run()
FileStoreMonitor	setMaxUsage(double maxUsage)
void	tick()

Methods inherited from class org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

delay, getPeriod, getTimeUnit, isStarted, setPeriod, setTimeUnit, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

FileStoreMonitor

public FileStoreMonitor(ScheduledExecutorService scheduledExecutorService,
                        Executor executor,
                        long checkPeriod,
                        TimeUnit timeUnit,
                        double maxUsage)

Method Detail

addCallback

public FileStoreMonitor addCallback(FileStoreMonitor.Callback callback)

addStore

public FileStoreMonitor addStore(File file)
                          throws IOException

Throws:

IOException

addStore

public FileStoreMonitor addStore(FileStore store)

run

public void run()

tick

public void tick()

getMaxUsage

public double getMaxUsage()

setMaxUsage

public FileStoreMonitor setMaxUsage(double maxUsage)

calculateUsage

protected double calculateUsage(FileStore store)
                         throws IOException

Throws:

IOException