Package org.apache.activemq.artemis.core.messagecounter.impl

Class MessageCounterManagerImpl

java.lang.Object

org.apache.activemq.artemis.core.messagecounter.impl.MessageCounterManagerImpl

All Implemented Interfaces:

MessageCounterManager

public class MessageCounterManagerImpl
extends Object
implements MessageCounterManager

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_DAY_COUNT
static final long	DEFAULT_SAMPLE_PERIOD
static final long	MIN_SAMPLE_PERIOD

Constructor Summary

Constructors

Constructor	Description
MessageCounterManagerImpl(ScheduledExecutorService scheduledThreadPool, Executor executor)

Method Summary

Modifier and Type	Method	Description
void	clear()
int	getMaxDayCount()
MessageCounter	getMessageCounter(String counter)
Set<MessageCounter>	getMessageCounters()
long	getSamplePeriod()
void	registerMessageCounter(String name, MessageCounter counter)
void	reschedule(long newPeriod)
void	resetAllCounterHistories()
void	resetAllCounters()
void	setMaxDayCount(int count)
void	start()
void	stop()
MessageCounter	unregisterMessageCounter(String name)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SAMPLE_PERIOD

public static final long DEFAULT_SAMPLE_PERIOD

MIN_SAMPLE_PERIOD

public static final long MIN_SAMPLE_PERIOD

See Also:

• Constant Field Values

DEFAULT_MAX_DAY_COUNT

public static final int DEFAULT_MAX_DAY_COUNT

Constructor Details

MessageCounterManagerImpl

public MessageCounterManagerImpl(ScheduledExecutorService scheduledThreadPool,
 Executor executor)

Method Details

start

public void start()

Specified by:

start in interface MessageCounterManager

stop

public void stop()

Specified by:

stop in interface MessageCounterManager

clear

public void clear()

Specified by:

clear in interface MessageCounterManager

reschedule

public void reschedule(long newPeriod)

Specified by:

reschedule in interface MessageCounterManager

getSamplePeriod

public long getSamplePeriod()

Specified by:

getSamplePeriod in interface MessageCounterManager

getMaxDayCount

public int getMaxDayCount()

Specified by:

getMaxDayCount in interface MessageCounterManager

setMaxDayCount

public void setMaxDayCount(int count)

Specified by:

setMaxDayCount in interface MessageCounterManager

registerMessageCounter

public void registerMessageCounter(String name,
 MessageCounter counter)

Specified by:

registerMessageCounter in interface MessageCounterManager

unregisterMessageCounter

public MessageCounter unregisterMessageCounter(String name)

Specified by:

unregisterMessageCounter in interface MessageCounterManager

getMessageCounter

public MessageCounter getMessageCounter(String counter)

getMessageCounters

public Set<MessageCounter> getMessageCounters()

resetAllCounters

public void resetAllCounters()

Specified by:

resetAllCounters in interface MessageCounterManager

resetAllCounterHistories

public void resetAllCounterHistories()

Specified by:

resetAllCounterHistories in interface MessageCounterManager