org.hornetq.core.messagecounter

Class MessageCounter

java.lang.Object

org.hornetq.core.messagecounter.MessageCounter

public class MessageCounter
extends Object

This class stores message count informations for a given queue At intervals this class samples the queue for message count data Note that the underlying queue *does not* update statistics every time a message is added since that would reall slow things down, instead we *sample* the queues at regular intervals - this means we are less intrusive on the queue

Version:

$Revision: 1.8 $

Author:

Ulf Schroeter, Stephan Steinbacher, Tim Fox

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessageCounter.DayCounter Internal day counter class for one day hour based counter history

Constructor Summary

Constructors

Constructor and Description
MessageCounter(String name, String subscription, Queue serverQueue, boolean topic, boolean durable, int daycountmax) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
long	getCount() Gets the total message count since startup or last counter reset
long	getCountDelta() Gets the message count delta since last method call
String	getDestinationName()
String	getDestinationSubscription()
List<MessageCounter.DayCounter>	getHistory()
String	getHistoryAsString() Get message counter history data as string in format "day count\n Date 1, hour counter 0, hour counter 1, ..., hour counter 23\n Date 2, hour counter 0, hour counter 1, ..., hour counter 23\n .....
long	getLastAddedMessageTime()
long	getLastUpdate()
long	getMessageCount() Gets the current message count of pending messages within the destination waiting for dispatch
long	getMessageCountDelta() Gets the message count delta of pending messages since last method call.
boolean	isDestinationDurable()
boolean	isDestinationTopic()
void	onTimer()
void	resetCounter()
void	resetHistory()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageCounter

public MessageCounter(String name,
              String subscription,
              Queue serverQueue,
              boolean topic,
              boolean durable,
              int daycountmax)

Constructor

Parameters:

name - destination name

subscription - subscription name

queue - internal queue object

topic - topic destination flag

durable - durable subsciption flag

daycountmax - max message history day count

Method Detail

onTimer

public void onTimer()

getDestinationName

public String getDestinationName()

getDestinationSubscription

public String getDestinationSubscription()

isDestinationTopic

public boolean isDestinationTopic()

isDestinationDurable

public boolean isDestinationDurable()

getCount

public long getCount()

Gets the total message count since startup or last counter reset

getCountDelta

public long getCountDelta()

Gets the message count delta since last method call

getMessageCount

public long getMessageCount()

Gets the current message count of pending messages within the destination waiting for dispatch

getMessageCountDelta

public long getMessageCountDelta()

Gets the message count delta of pending messages since last method call.

getLastUpdate

public long getLastUpdate()

getLastAddedMessageTime

public long getLastAddedMessageTime()

resetCounter

public void resetCounter()

resetHistory

public void resetHistory()

getHistory

public List<MessageCounter.DayCounter> getHistory()

getHistoryAsString

public String getHistoryAsString()

Get message counter history data as string in format "day count\n Date 1, hour counter 0, hour counter 1, ..., hour counter 23\n Date 2, hour counter 0, hour counter 1, ..., hour counter 23\n ..... ..... Date n, hour counter 0, hour counter 1, ..., hour counter 23\n"

Returns:

String message history data string

toString

public String toString()

Overrides:

toString in class Object