activemq::core::ActiveMQMessageAudit Class Reference

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

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

void activemq::core::ActiveMQMessageAudit::getMaximumNumberOfProducersToTrack

(

int

value

)

Sets the number of producers to track.

Parameters:

value

The number of producers expected in the system

int activemq::core::ActiveMQMessageAudit::getMaximumNumberOfProducersToTrack

(

)

const

Returns:

the current number of producers that will be tracked.

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::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::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.

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.

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::rollback

(

const std::string &

msgId

)

Marks this message as being received.

Parameters:

msgId

The string value Message Id.

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