From 56e808fda39091678bfa4db8d9ef9a0148898c28 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Wed, 19 Jun 2013 14:52:11 +0000
Subject: NO-JIRA: remove unused code

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1494646 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/Queue.cpp | 31 -------------------------------
 1 file changed, 31 deletions(-)

(limited to 'cpp/src/qpid/broker/Queue.cpp')

diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index cbc5c86dad..e1782b01ce 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -178,8 +178,6 @@ Queue::Queue(const string& _name, const QueueSettings& _settings,
     consumerCount(0),
     browserCount(0),
     exclusive(0),
-    persistLastNode(false),
-    inLastNodeFailure(false),
     messages(new MessageDeque()),
     persistenceId(0),
     settings(b ? merge(_settings, b->getOptions()) : _settings),
@@ -795,31 +793,6 @@ bool Queue::canAutoDelete() const
     return settings.autodelete && !consumerCount && !owner;
 }
 
-void Queue::clearLastNodeFailure()
-{
-    inLastNodeFailure = false;
-}
-
-void Queue::forcePersistent(const Message& /*message*/)
-{
-    //TODO
-}
-
-void Queue::setLastNodeFailure()
-{
-    if (persistLastNode){
-        Mutex::ScopedLock locker(messageLock);
-        try {
-            messages->foreach(boost::bind(&Queue::forcePersistent, this, _1));
-        } catch (const std::exception& e) {
-            // Could not go into last node standing (for example journal not large enough)
-            QPID_LOG(error, "Unable to fail to last node standing for queue: " << name << " : " << e.what());
-        }
-        inLastNodeFailure = true;
-    }
-}
-
-
 /*
  * return true if enqueue succeeded and message should be made
  * available; returning false will result in the message being dropped
@@ -837,10 +810,6 @@ bool Queue::enqueue(TransactionContext* ctxt, Message& msg)
         }
     }
 
-    if (inLastNodeFailure && persistLastNode){
-        forcePersistent(msg);
-    }
-
     if (settings.traceId.size()) {
         msg.addTraceId(settings.traceId);
     }
-- 
cgit v1.2.1