diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Consumer.h')
-rw-r--r-- | qpid/cpp/src/qpid/broker/Consumer.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/Consumer.h b/qpid/cpp/src/qpid/broker/Consumer.h index 3330e3918f..b3d6f23732 100644 --- a/qpid/cpp/src/qpid/broker/Consumer.h +++ b/qpid/cpp/src/qpid/broker/Consumer.h @@ -70,6 +70,11 @@ class Consumer */ virtual void acknowledged(const QueuedMessage&) = 0; + /** Called if queue has been deleted, if true suppress the error message. + * Used by HA ReplicatingSubscriptions where such errors are normal. + */ + virtual bool hideDeletedError() { return false; } + protected: framing::SequenceNumber position; |