From d19657d82321b2b5e2cac386c49aa99f82b976fb Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 7 Nov 2007 16:06:31 +0000 Subject: Added LocalQueue subscriptions. LocalQueue::pop() provides a "pull" alternative to the MessageListener::received() "push" API. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592803 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/sys/BlockingQueue.h | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) (limited to 'cpp/src/qpid/sys') diff --git a/cpp/src/qpid/sys/BlockingQueue.h b/cpp/src/qpid/sys/BlockingQueue.h index 65196dbd9c..c53949ad6f 100644 --- a/cpp/src/qpid/sys/BlockingQueue.h +++ b/cpp/src/qpid/sys/BlockingQueue.h @@ -29,8 +29,6 @@ namespace qpid { namespace sys { -struct QueueClosed {}; - template class BlockingQueue { @@ -46,7 +44,7 @@ public: T pop() { Waitable::ScopedLock l(lock); - if (!queueWait()) throw QueueClosed(); + if (!queueWait()) throw ClosedException(); return popInternal(); } @@ -78,7 +76,7 @@ public: } /** - * Close the queue. Throws QueueClosed in threads waiting in pop(). + * Close the queue. Throws ClosedException in threads waiting in pop(). * Blocks till all waiting threads have been notified. */ void close() -- cgit v1.2.1