org.hornetq.core.messagecounter.impl

Class MessageCounterManagerImpl

java.lang.Object

org.hornetq.core.messagecounter.impl.MessageCounterManagerImpl

All Implemented Interfaces:

MessageCounterManager

public class MessageCounterManagerImpl
extends Object
implements MessageCounterManager

A MessageCounterManager

Version:

$Revision: 3307 $ $Id: MessageCounterManager.java 3307 2007-11-09 20:43:00Z timfox $

Author:

Tim Fox, Jeff Mesnil

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
MessageCounterManagerImpl(ScheduledExecutorService scheduledThreadPool)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
int	getMaxDayCount()
MessageCounter	getMessageCounter(String name)
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 Detail

DEFAULT_SAMPLE_PERIOD

public static final long DEFAULT_SAMPLE_PERIOD

See Also:

Constant Field Values

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

See Also:

Constant Field Values

Constructor Detail

MessageCounterManagerImpl

public MessageCounterManagerImpl(ScheduledExecutorService scheduledThreadPool)

Method Detail

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

getMessageCounters

public Set<MessageCounter> getMessageCounters()

getMessageCounter

public MessageCounter getMessageCounter(String name)

resetAllCounters

public void resetAllCounters()

Specified by:

resetAllCounters in interface MessageCounterManager

resetAllCounterHistories

public void resetAllCounterHistories()

Specified by:

resetAllCounterHistories in interface MessageCounterManager