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 | 56e808fda39091678bfa4db8d9ef9a0148898c28 (patch) | |
| tree | e32eca4e4cfcd0fd62ce97c92f8f9c2f66f81513 /cpp/src/qpid/broker/Queue.cpp | |
| parent | 4b873700c63ad75817af0c59bfc7b962990a8436 (diff) | |
| download | qpid-python-56e808fda39091678bfa4db8d9ef9a0148898c28.tar.gz | |
NO-JIRA: remove unused code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1494646 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Queue.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 31 |
1 files changed, 0 insertions, 31 deletions
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); } |
