diff options
author | Gordon Sim <gsim@apache.org> | 2013-06-19 14:52:11 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2013-06-19 14:52:11 +0000 |
commit | 3ed7df0bb26d82b63a2d0a2f47db79693220cb02 (patch) | |
tree | 159aa8f4cb2c47635e191275c6a071ba83eb2318 /qpid/cpp/src/qpid/broker/Queue.h | |
parent | 36b93a14e9325a466bb4b231aa2bf4d9b68ecd5b (diff) | |
download | qpid-python-3ed7df0bb26d82b63a2d0a2f47db79693220cb02.tar.gz |
NO-JIRA: remove unused code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1494646 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Queue.h')
-rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.h | 9 |
1 files changed, 0 insertions, 9 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.h b/qpid/cpp/src/qpid/broker/Queue.h index 8b8ef442b2..29b711075a 100644 --- a/qpid/cpp/src/qpid/broker/Queue.h +++ b/qpid/cpp/src/qpid/broker/Queue.h @@ -129,8 +129,6 @@ class Queue : public boost::enable_shared_from_this<Queue>, uint32_t consumerCount; // Actually a count of all subscriptions, acquiring or not. uint32_t browserCount; // Count of non-acquiring subscriptions. OwnershipToken* exclusive; - bool persistLastNode; - bool inLastNodeFailure; std::vector<std::string> traceExclude; QueueListeners listeners; std::auto_ptr<Messages> messages; @@ -200,7 +198,6 @@ class Queue : public boost::enable_shared_from_this<Queue>, bool acquire(const qpid::framing::SequenceNumber& position, Message& msg, const qpid::sys::Mutex::ScopedLock& locker); - void forcePersistent(const Message& msg); int getEventMode(); void dequeueFromStore(boost::intrusive_ptr<PersistableMessage>); void abandoned(const Message& message); @@ -314,12 +311,6 @@ class Queue : public boost::enable_shared_from_this<Queue>, const QueueBindings& getBindings() const { return bindings; } /** - * used to take messages from in memory and flush down to disk. - */ - QPID_BROKER_EXTERN void setLastNodeFailure(); - QPID_BROKER_EXTERN void clearLastNodeFailure(); - - /** * dequeue from store (only done once messages is acknowledged) */ QPID_BROKER_EXTERN void dequeue(TransactionContext* ctxt, const QueueCursor&); |