18#ifndef _ACTIVEMQ_CORE_CONNECTIONAUDIT_H_
19#define _ACTIVEMQ_CORE_CONNECTIONAUDIT_H_
29 class ConnectionAuditImpl;
41 ConnectionAudit(
const ConnectionAudit&);
42 ConnectionAudit& operator= (
const ConnectionAudit&);
46 ConnectionAuditImpl* impl;
48 bool checkForDuplicates;
50 int auditMaximumProducerNumber;
71 return this->checkForDuplicates;
75 this->checkForDuplicates = checkForDuplicates;
83 this->auditDepth = auditDepth;
87 return auditMaximumProducerNumber;
91 this->auditMaximumProducerNumber = auditMaximumProducerNumber;
#define AMQCPP_API
Definition Config.h:30
bool isCheckForDuplicates() const
Definition ConnectionAudit.h:70
void setAuditMaximumProducerNumber(int auditMaximumProducerNumber)
Definition ConnectionAudit.h:90
void rollbackDuplicate(Dispatcher *dispatcher, decaf::lang::Pointer< commands::Message > message)
void setAuditDepth(int auditDepth)
Definition ConnectionAudit.h:82
int getAuditDepth()
Definition ConnectionAudit.h:78
ConnectionAudit(int auditDepth, int maxProducers)
void removeDispatcher(Dispatcher *dispatcher)
bool isDuplicate(Dispatcher *dispatcher, decaf::lang::Pointer< commands::Message > message)
void setCheckForDuplicates(bool checkForDuplicates)
Definition ConnectionAudit.h:74
int getAuditMaximumProducerNumber()
Definition ConnectionAudit.h:86
Interface for an object responsible for dispatching messages to consumers.
Definition Dispatcher.h:32
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Definition ActiveMQTempDestination.h:29
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24