summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/broker/Queue.h
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
commit3ed7df0bb26d82b63a2d0a2f47db79693220cb02 (patch)
tree159aa8f4cb2c47635e191275c6a071ba83eb2318 /qpid/cpp/src/qpid/broker/Queue.h
parent36b93a14e9325a466bb4b231aa2bf4d9b68ecd5b (diff)
downloadqpid-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.h9
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&);