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, 10 insertions, 0 deletions

diff --git a/qpid/cpp/tests/ConfigurationTest.cpp b/qpid/cpp/tests/ConfigurationTest.cpp
index c2c8eb6f32..3a1d5ba85d 100644
--- a/qpid/cpp/tests/ConfigurationTest.cpp
+++ b/qpid/cpp/tests/ConfigurationTest.cpp
@@ -32,6 +32,7 @@ class ConfigurationTest : public CppUnit::TestCase
     CPPUNIT_TEST(testPortLongForm);
     CPPUNIT_TEST(testPortShortForm);
     CPPUNIT_TEST(testStore);
+    CPPUNIT_TEST(testStagingThreshold);
     CPPUNIT_TEST(testVarious);
     CPPUNIT_TEST_SUITE_END();
 
@@ -70,6 +71,15 @@ class ConfigurationTest : public CppUnit::TestCase
         CPPUNIT_ASSERT_EQUAL(expected, conf.getStore());
     }
 
+    void testStagingThreshold() 
+    {
+        Configuration conf;
+        char* argv[] = {"ignore", "--staging-threshold", "123456789"};
+        conf.parse("ignore", 3, argv);
+        long expected = 123456789;
+        CPPUNIT_ASSERT_EQUAL(expected, conf.getStagingThreshold());
+    }
+
     void testVarious() 
     {        
         Configuration conf;