diff options
author | Alan Conway <aconway@apache.org> | 2011-07-28 18:28:56 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2011-07-28 18:28:56 +0000 |
commit | 95ad2adfc443b227eba224279188c36906c1db66 (patch) | |
tree | 14c91400e2284b2c4f782d203a60d44dbee31f9e /qpid/cpp/src/qpid/broker/QueuePolicy.h | |
parent | 8db25489a2971803b21d73814521b40731111bd5 (diff) | |
download | qpid-python-qpid-3163.tar.gz |
Merge branch 'visibility-hidden' into qpid-3163qpid-3163
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3163@1151956 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/QueuePolicy.h')
-rw-r--r-- | qpid/cpp/src/qpid/broker/QueuePolicy.h | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/broker/QueuePolicy.h b/qpid/cpp/src/qpid/broker/QueuePolicy.h index 3cdd63784d..22b3725d3c 100644 --- a/qpid/cpp/src/qpid/broker/QueuePolicy.h +++ b/qpid/cpp/src/qpid/broker/QueuePolicy.h @@ -7,9 +7,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 @@ -33,7 +33,7 @@ namespace qpid { namespace broker { -class QueuePolicy +class QPID_BROKER_CLASS_EXTERN QueuePolicy { static uint64_t defaultMaxSize; @@ -43,11 +43,11 @@ class QueuePolicy uint32_t count; uint64_t size; bool policyExceeded; - + static uint32_t getCapacity(const qpid::framing::FieldTable& settings, const std::string& key, uint32_t defaultValue); protected: - uint64_t getCurrentQueueSize() const { return size; } + uint64_t getCurrentQueueSize() const { return size; } public: typedef std::deque<QueuedMessage> Messages; @@ -57,7 +57,7 @@ class QueuePolicy static QPID_BROKER_EXTERN const std::string REJECT; static QPID_BROKER_EXTERN const std::string FLOW_TO_DISK; static QPID_BROKER_EXTERN const std::string RING; - static QPID_BROKER_EXTERN const std::string RING_STRICT; + static QPID_BROKER_EXTERN const std::string RING_STRICT; virtual ~QueuePolicy() {} QPID_BROKER_EXTERN void tryEnqueue(boost::intrusive_ptr<Message> msg); @@ -68,7 +68,7 @@ class QueuePolicy virtual bool isEnqueued(const QueuedMessage&); QPID_BROKER_EXTERN void update(qpid::framing::FieldTable& settings); uint32_t getMaxCount() const { return maxCount; } - uint64_t getMaxSize() const { return maxSize; } + uint64_t getMaxSize() const { return maxSize; } void encode(framing::Buffer& buffer) const; void decode ( framing::Buffer& buffer ); uint32_t encodedSize() const; |