Initial implementation (plus very simple tests) of message.acquire, message.release, message.reject and message.flush.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@572394 13f79535-47bb-0310-9956-ffa450edef68

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(){}
         };