Added new configuration option for staging threshold (size above which messages

will be written to disk as content arrives rather than accumulating that content 
in memory). Pass this through to all channels and to the store on recovery.



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

1 files changed, 3 insertions, 2 deletions

diff --git a/qpid/cpp/lib/broker/SessionHandlerFactoryImpl.h b/qpid/cpp/lib/broker/SessionHandlerFactoryImpl.h
index 73ae879a58..a69b67b08d 100644
--- a/qpid/cpp/lib/broker/SessionHandlerFactoryImpl.h
+++ b/qpid/cpp/lib/broker/SessionHandlerFactoryImpl.h
@@ -31,6 +31,7 @@
 #include <sys/SessionHandler.h>
 #include <sys/SessionHandlerFactory.h>
 #include <sys/TimeoutHandler.h>
+#include <SessionHandlerImpl.h>
 #include <memory>
 
 namespace qpid {
@@ -41,10 +42,10 @@ namespace qpid {
             std::auto_ptr<MessageStore> store;
             QueueRegistry queues;
             ExchangeRegistry exchanges;
-            const u_int32_t timeout;//timeout for auto-deleted queues (in ms)
+            const Settings settings;
             AutoDelete cleaner;
         public:
-            SessionHandlerFactoryImpl(const std::string& store = "", u_int32_t timeout = 30000);
+            SessionHandlerFactoryImpl(const std::string& store = "", u_int64_t stagingThreshold = 0, u_int32_t timeout = 30000);
             virtual qpid::sys::SessionHandler* create(qpid::sys::SessionContext* ctxt);
             virtual ~SessionHandlerFactoryImpl();
         };