org.activemq
Class ActiveMQMessageAudit

java.lang.Object
org.activemq.ActiveMQMessageAudit
- public class ActiveMQMessageAudit
- extends java.lang.Object
Provides basic audit functions for Messages
- Version:
- $Revision: 1.1.1.1 $
|
Constructor Summary |
ActiveMQMessageAudit()
Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128 |
ActiveMQMessageAudit(int windowSize,
int maximumNumberOfProducersToTrack)
Construct a MessageAudit |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_WINDOW_SIZE
private static final int DEFAULT_WINDOW_SIZE
- See Also:
- Constant Field Values
MAXIMUM_PRODUCER_COUNT
private static final int MAXIMUM_PRODUCER_COUNT
- See Also:
- Constant Field Values
windowSize
private int windowSize
map
private java.util.LinkedHashMap map
ActiveMQMessageAudit
public ActiveMQMessageAudit()
- Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128
ActiveMQMessageAudit
public ActiveMQMessageAudit(int windowSize,
int maximumNumberOfProducersToTrack)
- Construct a MessageAudit
isDuplicate
public boolean isDuplicate(javax.jms.Message message)
throws javax.jms.JMSException
- Checks if this message has beeb seen before
isDuplicate
public boolean isDuplicate(java.lang.String id)
- checks whether this messageId has been seen before and adds this messageId to the list