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(javax.jms.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(javax.jms.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
|
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) |
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(javax.jms.Message message) throws javax.jms.JMSException
message
- javax.jms.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 void rollback(MessageId id)
id
- public void rollback(String id)
public boolean isInOrder(javax.jms.Message msg) throws javax.jms.JMSException
msg
- javax.jms.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()
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.