public class ActiveMQMessageAuditNoSync extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_WINDOW_SIZE |
static int |
MAXIMUM_PRODUCER_COUNT |
Constructor and Description |
---|
ActiveMQMessageAuditNoSync()
Default Constructor windowSize = 2048, maximumNumberOfProducersToTrack = 64
|
ActiveMQMessageAuditNoSync(int auditDepth,
int maximumNumberOfProducersToTrack)
Construct a MessageAudit
|
Modifier and Type | Method and Description |
---|---|
void |
clear() |
int |
getAuditDepth() |
long |
getLastSeqId(ProducerId id) |
int |
getMaximumNumberOfProducersToTrack() |
boolean |
isDuplicate(Message message)
Checks if this message has been seen before
|
boolean |
isDuplicate(MessageId id)
Checks if this messageId has been seen before
|
boolean |
isDuplicate(MessageReference message)
Checks if this message 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(Message msg)
Check the message is in order
|
boolean |
isInOrder(MessageId id)
Check the MessageId is in order
|
boolean |
isInOrder(MessageReference message)
Check the MessageId is in order
|
boolean |
isInOrder(String id)
Check the message id is in order
|
boolean |
isModified()
Returns if the Audit has been modified since last check, this method does not
reset the modified flag.
|
boolean |
modified()
Reads and returns the current modified state of the Audit, once called the state is
reset to false.
|
void |
rollback(MessageId id)
mark this message as being received
|
void |
rollback(MessageReference message)
mark this message as being received
|
void |
rollback(String id) |
void |
setAuditDepth(int auditDepth) |
void |
setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack) |
void |
setModified(boolean modified) |
public static final int DEFAULT_WINDOW_SIZE
public static final int MAXIMUM_PRODUCER_COUNT
public ActiveMQMessageAuditNoSync()
public ActiveMQMessageAuditNoSync(int auditDepth, int maximumNumberOfProducersToTrack)
auditDepth
- range of ids to trackmaximumNumberOfProducersToTrack
- number of producers expected in the systempublic int getAuditDepth()
public void setAuditDepth(int auditDepth)
auditDepth
- the auditDepth to setpublic int getMaximumNumberOfProducersToTrack()
public void setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack)
maximumNumberOfProducersToTrack
- the maximumNumberOfProducersToTrack to setpublic boolean isDuplicate(Message message) throws JMSException
message
- JMSException
public boolean isDuplicate(String id)
id
- public boolean isDuplicate(MessageReference message)
message
- public boolean isDuplicate(MessageId id)
id
- public void rollback(MessageReference message)
message
- public boolean isInOrder(Message msg) throws JMSException
msg
- JMSException
public boolean isInOrder(String id)
id
- public boolean isInOrder(MessageReference message)
message
- public boolean isInOrder(MessageId id)
id
- public long getLastSeqId(ProducerId id)
public void clear()
public boolean isModified()
public void setModified(boolean modified)
public boolean modified()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.