activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r675606 - /activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConsumer.cpp
Date Thu, 10 Jul 2008 15:03:17 GMT
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 ){



Mime
View raw message