public class ActiveMQMessageAudit extends ActiveMQMessageAuditNoSync
DEFAULT_WINDOW_SIZE, MAXIMUM_PRODUCER_COUNT
Constructor and Description |
---|
ActiveMQMessageAudit()
Default Constructor windowSize = 2048, maximumNumberOfProducersToTrack =
64
|
ActiveMQMessageAudit(int auditDepth,
int maximumNumberOfProducersToTrack)
Construct a MessageAudit
|
Modifier and Type | Method and Description |
---|---|
boolean |
isDuplicate(MessageId id)
Checks if this messageId has been seen before
|
boolean |
isDuplicate(String id)
checks whether this messageId has been seen before and adds this
messageId to the list
|
boolean |
isInOrder(MessageId id)
Check the MessageId is in order
|
boolean |
isInOrder(String id)
Check the message id is in order
|
void |
rollback(MessageId id)
mark this message as being received
|
void |
setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack) |
clear, getAuditDepth, getLastSeqId, getMaximumNumberOfProducersToTrack, isDuplicate, isDuplicate, isInOrder, isInOrder, isModified, modified, rollback, rollback, setAuditDepth, setModified
public ActiveMQMessageAudit()
public ActiveMQMessageAudit(int auditDepth, int maximumNumberOfProducersToTrack)
auditDepth
- range of ids to trackmaximumNumberOfProducersToTrack
- number of producers expected in
the systempublic boolean isDuplicate(String id)
ActiveMQMessageAuditNoSync
isDuplicate
in class ActiveMQMessageAuditNoSync
public boolean isDuplicate(MessageId id)
ActiveMQMessageAuditNoSync
isDuplicate
in class ActiveMQMessageAuditNoSync
public void rollback(MessageId id)
ActiveMQMessageAuditNoSync
rollback
in class ActiveMQMessageAuditNoSync
public boolean isInOrder(String id)
ActiveMQMessageAuditNoSync
isInOrder
in class ActiveMQMessageAuditNoSync
public boolean isInOrder(MessageId id)
ActiveMQMessageAuditNoSync
isInOrder
in class ActiveMQMessageAuditNoSync
public void setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack)
setMaximumNumberOfProducersToTrack
in class ActiveMQMessageAuditNoSync
maximumNumberOfProducersToTrack
- the maximumNumberOfProducersToTrack to setCopyright © 2005–2019 The Apache Software Foundation. All rights reserved.