diff options
| author | Gordon Sim <gsim@apache.org> | 2006-12-06 12:01:40 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2006-12-06 12:01:40 +0000 |
| commit | 5ee8574ae432294f56f60ced5cfde3082cfd2dba (patch) | |
| tree | c7ff45a2d70b66ab31b35021e4c73ae295510280 /qpid/cpp/lib/broker/QueueRegistry.cpp | |
| parent | 69520adb359ca50918c802611e300887bcfd5bea (diff) | |
| download | qpid-python-5ee8574ae432294f56f60ced5cfde3082cfd2dba.tar.gz | |
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
Diffstat (limited to 'qpid/cpp/lib/broker/QueueRegistry.cpp')
| -rw-r--r-- | qpid/cpp/lib/broker/QueueRegistry.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/cpp/lib/broker/QueueRegistry.cpp b/qpid/cpp/lib/broker/QueueRegistry.cpp index 304f696a7f..2d1382ef09 100644 --- a/qpid/cpp/lib/broker/QueueRegistry.cpp +++ b/qpid/cpp/lib/broker/QueueRegistry.cpp @@ -73,3 +73,7 @@ string QueueRegistry::generateName(){ } while(queues.find(name) != queues.end()); return name; } + +MessageStore* const QueueRegistry::getStore() const { + return store; +} |