activemq::core::ActiveMQMessageAudit Class Reference

#include <src/main/activemq/core/ActiveMQMessageAudit.h>

Public Member Functions
	ActiveMQMessageAudit ()
	Default Constructor windowSize = 2048, maximumNumberOfProducersToTrack = 64. More...
	ActiveMQMessageAudit (int auditDepth, int maximumNumberOfProducersToTrack)
	Construct a MessageAudit. More...
	~ActiveMQMessageAudit ()
int	getAuditDepth () const
	Gets the currently configured Audit Depth. More...
void	setAuditDepth (int value)
	Sets a new Audit Depth value. More...
int	getMaximumNumberOfProducersToTrack () const
void	getMaximumNumberOfProducersToTrack (int value)
	Sets the number of producers to track. More...
bool	isDuplicate (const std::string &msgId) const
	checks whether this messageId has been seen before and adds this messageId to the list More...
bool	isDuplicate (decaf::lang::Pointer< commands::MessageId > msgId) const
	Checks if this messageId has been seen before. More...
void	rollback (const std::string &msgId)
	Marks this message as being received. More...
void	rollback (decaf::lang::Pointer< commands::MessageId > msgId)
	Marks this message as being received. More...
bool	isInOrder (const std::string &msgId) const
	Check the MessageId is in order. More...
bool	isInOrder (decaf::lang::Pointer< commands::MessageId > msgId) const
	Check the MessageId is in order. More...
long long	getLastSeqId (decaf::lang::Pointer< commands::ProducerId > id) const
void	clear ()
	Clears this Audit. More...

Static Public Attributes
static const int	DEFAULT_WINDOW_SIZE
static const int	MAXIMUM_PRODUCER_COUNT

Constructor & Destructor Documentation

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

(

)

Member Function Documentation

void activemq::core::ActiveMQMessageAudit::clear

(

)

Clears this Audit.

int activemq::core::ActiveMQMessageAudit::getAuditDepth

(

)

const

Gets the currently configured Audit Depth.

Returns

the current audit depth setting

long long activemq::core::ActiveMQMessageAudit::getLastSeqId

(

decaf::lang::Pointer< commands::ProducerId >

id

)

const

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.

bool activemq::core::ActiveMQMessageAudit::isDuplicate

(

decaf::lang::Pointer< commands::MessageId >

msgId

)

const

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.

bool activemq::core::ActiveMQMessageAudit::isInOrder

(

decaf::lang::Pointer< commands::MessageId >

msgId

)

const

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.

void activemq::core::ActiveMQMessageAudit::rollback

(

decaf::lang::Pointer< commands::MessageId >

msgId

)

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.

Field Documentation

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:

• src/main/activemq/core/ActiveMQMessageAudit.h