From 8455ba0b116208f47ce238b384d4af274fa0edb6 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 14 Jan 2010 18:55:46 +0000 Subject: Removed dead code: OutputTask::hasOutput and Queue::checkForMessages. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@899356 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/Queue.cpp | 26 -------------------------- 1 file changed, 26 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 068ebe3103..b99b849bcc 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -309,32 +309,6 @@ bool Queue::getNextMessage(QueuedMessage& m, Consumer::shared_ptr c) } } -bool Queue::checkForMessages(Consumer::shared_ptr c) -{ - Mutex::ScopedLock locker(messageLock); - if (messages.empty()) { - //no message available, register consumer for notification - //when this changes - listeners.addListener(c); - return false; - } else { - QueuedMessage msg = getFront(); - if (store && !msg.payload->isEnqueueComplete()) { - //though a message is on the queue, it has not yet been - //enqueued and so is not available for consumption yet, - //register consumer for notification when this changes - listeners.addListener(c); - return false; - } else { - //check that consumer has sufficient credit for the - //message (if it does not, no need to register it for - //notification as the consumer itself will handle the - //credit allocation required to change this condition). - return c->accept(msg.payload); - } - } -} - Queue::ConsumeCode Queue::consumeNextMessage(QueuedMessage& m, Consumer::shared_ptr c) { while (true) { -- cgit v1.2.1