summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/PersistableQueue.h
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2009-09-11 13:33:42 +0000
committerKim van der Riet <kpvdr@apache.org>2009-09-11 13:33:42 +0000
commitb171cc419ae5d2bc747ec2465ad1c76445f8bd37 (patch)
tree2f4d01f55832b1cee196214eae31af47f4ca4a78 /cpp/src/qpid/broker/PersistableQueue.h
parent613071992900172cb00b5eff9f39b1cc06a5e2a8 (diff)
downloadqpid-python-b171cc419ae5d2bc747ec2465ad1c76445f8bd37.tar.gz
Joint checkin with cctrieloff. Refactor of exchange routing so that multi-queue policy differences may be resolved and allow for correct multi-queue flow-to-disk behavior. Different queues may have differing policies and persistence properties - these were previously being neglected. New c++ test added.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@813825 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/PersistableQueue.h')
-rw-r--r--cpp/src/qpid/broker/PersistableQueue.h18
1 files changed, 9 insertions, 9 deletions
diff --git a/cpp/src/qpid/broker/PersistableQueue.h b/cpp/src/qpid/broker/PersistableQueue.h
index 8d85d36fef..aa6a751f61 100644
--- a/cpp/src/qpid/broker/PersistableQueue.h
+++ b/cpp/src/qpid/broker/PersistableQueue.h
@@ -10,9 +10,9 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -55,18 +55,18 @@ public:
virtual const std::string& getName() const = 0;
virtual ~PersistableQueue() {
- if (externalQueueStore)
+ if (externalQueueStore)
delete externalQueueStore;
};
virtual void setExternalQueueStore(ExternalQueueStore* inst) = 0;
-
+
inline ExternalQueueStore* getExternalQueueStore() const {return externalQueueStore;};
-
+
PersistableQueue():externalQueueStore(NULL){
};
-
-
+
+
/**
* call back to signal async AIO writes have
* completed (enqueue/dequeue etc)
@@ -76,9 +76,9 @@ public:
*/
virtual void notifyDurableIOComplete() = 0;
protected:
-
+
ExternalQueueStore* externalQueueStore;
-
+
};
}}