Initial sketching out of staging functionality for large messages (i.e. allowing content to be stored as it arrives, rather than collecting it in memory until complete).

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

1 files changed, 14 insertions, 10 deletions

diff --git a/cpp/src/qpid/broker/NullMessageStore.h b/cpp/src/qpid/broker/NullMessageStore.h
index 7916467091..5b363db662 100644
--- a/cpp/src/qpid/broker/NullMessageStore.h
+++ b/cpp/src/qpid/broker/NullMessageStore.h
@@ -32,17 +32,21 @@ namespace qpid {
          * A null implementation of the MessageStore interface
          */
         class NullMessageStore : public MessageStore{
+            const bool warn;
         public:
-            void create(const Queue& queue);
-            void destroy(const Queue& queue);
-            void recover(RecoveryManager& queues);
-            void enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const Queue& queue, const string * const xid);
-            void dequeue(TransactionContext* ctxt, Message::shared_ptr& msg, const Queue& queue, const string * const xid);
-            void committed(const string * const xid);
-            void aborted(const string * const xid);
-            std::auto_ptr<TransactionContext> begin();
-            void commit(TransactionContext* ctxt);
-            void abort(TransactionContext* ctxt);
+            NullMessageStore(bool warn = true);
+            void virtual create(const Queue& queue);
+            void virtual destroy(const Queue& queue);
+            void virtual recover(RecoveryManager& queues);
+            void virtual stage(Message::shared_ptr& msg);
+            void virtual destroy(Message::shared_ptr& msg);
+            void virtual enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const Queue& queue, const string * const xid);
+            void virtual dequeue(TransactionContext* ctxt, Message::shared_ptr& msg, const Queue& queue, const string * const xid);
+            void virtual committed(const string * const xid);
+            void virtual aborted(const string * const xid);
+            virtual std::auto_ptr<TransactionContext> begin();
+            void virtual commit(TransactionContext* ctxt);
+            void virtual abort(TransactionContext* ctxt);
             ~NullMessageStore(){}
         };
     }