summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Queue.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2013-06-19 14:52:11 +0000
committerGordon Sim <gsim@apache.org>2013-06-19 14:52:11 +0000
commit56e808fda39091678bfa4db8d9ef9a0148898c28 (patch)
treee32eca4e4cfcd0fd62ce97c92f8f9c2f66f81513 /cpp/src/qpid/broker/Queue.cpp
parent4b873700c63ad75817af0c59bfc7b962990a8436 (diff)
downloadqpid-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.cpp31
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);
}