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