org.apache.activemq
Class ActiveMQMessageAudit

java.lang.Object
  org.apache.activemq.ActiveMQMessageAudit

public class ActiveMQMessageAudit
extends Object

Provides basic audit functions for Messages

Version:

$Revision: 1.1.1.1 $

Constructor Summary

ActiveMQMessageAudit()
Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128

ActiveMQMessageAudit(int auditDepth, int maximumNumberOfProducersToTrack)
Construct a MessageAudit

Method Summary

int	getAuditDepth()
int	getMaximumNumberOfProducersToTrack()
boolean	isDuplicate(Message message) Checks if this message has beeb 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(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	setAuditDepth(int auditDepth)
void	setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ActiveMQMessageAudit

public ActiveMQMessageAudit()

Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128

ActiveMQMessageAudit

public ActiveMQMessageAudit(int auditDepth,
                            int maximumNumberOfProducersToTrack)

Construct a MessageAudit

Parameters:

auditDepth - range of ids to track

maximumNumberOfProducersToTrack - number of producers expected in the system

Method Detail

getAuditDepth

public int getAuditDepth()

Returns:

the auditDepth

setAuditDepth

public void setAuditDepth(int auditDepth)

Parameters:

auditDepth - the auditDepth to set

getMaximumNumberOfProducersToTrack

public int getMaximumNumberOfProducersToTrack()

Returns:

the maximumNumberOfProducersToTrack

setMaximumNumberOfProducersToTrack

public void setMaximumNumberOfProducersToTrack(int maximumNumberOfProducersToTrack)

Parameters:

maximumNumberOfProducersToTrack - the maximumNumberOfProducersToTrack to set

isDuplicate

public boolean isDuplicate(Message message)
                    throws JMSException

Checks if this message has beeb seen before

Parameters:

message -

Returns:

true if the message is a duplicate

Throws:

JMSException

isDuplicate

public boolean isDuplicate(String id)

checks whether this messageId has been seen before and adds this messageId to the list

Parameters:

id -

Returns:

true if the message is a duplicate

isDuplicate

public boolean isDuplicate(MessageReference message)

Checks if this message has been seen before

Parameters:

message -

Returns:

true if the message is a duplicate

isDuplicate

public boolean isDuplicate(MessageId id)

Checks if this messageId has been seen before

Parameters:

id -

Returns:

true if the message is a duplicate

rollback

public void rollback(MessageReference message)

mark this message as being received

Parameters:

message -

rollback

public void rollback(MessageId id)

mark this message as being received

Parameters:

id -

isInOrder

public boolean isInOrder(Message msg)
                  throws JMSException

Check the message is in order

Parameters:

msg -

Returns:

Throws:

JMSException

isInOrder

public boolean isInOrder(String id)

Check the message id is in order

Parameters:

id -

Returns:

isInOrder

public boolean isInOrder(MessageReference message)

Check the MessageId is in order

Parameters:

message -

Returns:

isInOrder

public boolean isInOrder(MessageId id)

Check the MessageId is in order

Parameters:

id -

Returns: