summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Queue.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-01-18 16:28:17 +0000
committerAlan Conway <aconway@apache.org>2010-01-18 16:28:17 +0000
commit85bc39cb22f4915b5b03547e21b05db53d582551 (patch)
treeddf2fef5c6f008d684e796aba6a082871eede162 /cpp/src/qpid/broker/Queue.cpp
parente6918fe14a7a22da70d95c7afff7310eefba08f3 (diff)
downloadqpid-python-85bc39cb22f4915b5b03547e21b05db53d582551.tar.gz
QPID-2295: Clustered + persistent broker crashes with inconsistency error.
Code running in the store's timer thread was causing inconsistent changes in message allocation. This code is out-of-date, we no longer need to notify the Queue when persistent storage completes as the message is already available on the queue. Removed the out-dated code. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900448 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Queue.cpp')
-rw-r--r--cpp/src/qpid/broker/Queue.cpp10
1 files changed, 0 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index b99b849bcc..dcc5116afa 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -124,16 +124,6 @@ Queue::~Queue()
mgmtObject->resourceDestroy ();
}
-void Queue::notifyDurableIOComplete()
-{
- QueueListeners::NotificationSet copy;
- {
- Mutex::ScopedLock locker(messageLock);
- listeners.populate(copy);
- }
- copy.notify();
-}
-
bool isLocalTo(const OwnershipToken* token, boost::intrusive_ptr<Message>& msg)
{
return token && token->isLocal(msg->getPublisher());