Author: nmittler
Date: Thu Jul 10 08:03:16 2008
New Revision: 675606
URL: http://svn.apache.org/viewvc?rev=675606&view=rev
Log:
[AMQCPP-188] - Waking up synchronous consumers on a call to consumer.close()
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp
Modified: activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp?rev=675606&r1=675605&r2=675606&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp Thu Jul 10 08:03:16
2008
@@ -107,6 +107,12 @@
haveException = true;
}
}
+
+ // Wakeup any synchronous consumers.
+ synchronized( &unconsumedMessages )
+ {
+ unconsumedMessages.notifyAll();
+ }
// If we encountered an error, propagate it.
if( haveException ){
|