#include <src/main/activemq/core/ActiveMQMessageAudit.h>
activemq::core::ActiveMQMessageAudit::ActiveMQMessageAudit |
( |
| ) |
|
Default Constructor windowSize = 2048, maximumNumberOfProducersToTrack = 64.
activemq::core::ActiveMQMessageAudit::ActiveMQMessageAudit |
( |
int |
auditDepth, |
|
|
int |
maximumNumberOfProducersToTrack |
|
) |
| |
Construct a MessageAudit.
- Parameters
-
auditDepth | The range of ids to track. |
maximumNumberOfProducersToTrack | The number of producers expected in the system |
activemq::core::ActiveMQMessageAudit::~ActiveMQMessageAudit |
( |
| ) |
|
void activemq::core::ActiveMQMessageAudit::clear |
( |
| ) |
|
int activemq::core::ActiveMQMessageAudit::getAuditDepth |
( |
| ) |
const |
Gets the currently configured Audit Depth.
- Returns
- the current audit depth setting
- Returns
- the last sequence Id that we've audited for the given producer.
int activemq::core::ActiveMQMessageAudit::getMaximumNumberOfProducersToTrack |
( |
| ) |
const |
- Returns
- the current number of producers that will be tracked.
void activemq::core::ActiveMQMessageAudit::getMaximumNumberOfProducersToTrack |
( |
int |
value | ) |
|
Sets the number of producers to track.
- Parameters
-
value | The number of producers expected in the system |
bool activemq::core::ActiveMQMessageAudit::isDuplicate |
( |
const std::string & |
msgId | ) |
const |
checks whether this messageId has been seen before and adds this messageId to the list
- Parameters
-
msgId | The string value Message Id. |
- Returns
- true if the message is a duplicate.
Checks if this messageId has been seen before.
- Parameters
-
msgId | The target MessageId to check. |
- Returns
- true if the message is a duplicate
bool activemq::core::ActiveMQMessageAudit::isInOrder |
( |
const std::string & |
msgId | ) |
const |
Check the MessageId is in order.
- Parameters
-
msgId | The string value Message Id. |
- Returns
- true if the MessageId is in order.
Check the MessageId is in order.
- Parameters
-
msgId | The target MessageId to check. |
- Returns
- true if the MessageId is in order.
void activemq::core::ActiveMQMessageAudit::rollback |
( |
const std::string & |
msgId | ) |
|
Marks this message as being received.
- Parameters
-
msgId | The string value Message Id. |
Marks this message as being received.
- Parameters
-
msgId | The target MessageId to check. |
void activemq::core::ActiveMQMessageAudit::setAuditDepth |
( |
int |
value | ) |
|
Sets a new Audit Depth value.
- Parameters
-
value | The range of ids to track. |
const int activemq::core::ActiveMQMessageAudit::DEFAULT_WINDOW_SIZE |
|
static |
const int activemq::core::ActiveMQMessageAudit::MAXIMUM_PRODUCER_COUNT |
|
static |
The documentation for this class was generated from the following file: