summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Consumer.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/Consumer.h')
-rw-r--r--cpp/src/qpid/broker/Consumer.h7
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(){}
};