diff options
Diffstat (limited to 'cpp/src/qpid/broker/Consumer.h')
-rw-r--r-- | cpp/src/qpid/broker/Consumer.h | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Consumer.h b/cpp/src/qpid/broker/Consumer.h index 52da25082c..c482a44ab1 100644 --- a/cpp/src/qpid/broker/Consumer.h +++ b/cpp/src/qpid/broker/Consumer.h @@ -36,8 +36,13 @@ namespace qpid { }; - class Consumer{ + class Consumer { + const bool acquires; public: + framing::SequenceNumber position; + + Consumer(bool preAcquires = true) : acquires(preAcquires) {} + bool preAcquires() const { return acquires; } virtual bool deliver(QueuedMessage& msg) = 0; virtual ~Consumer(){} }; |