activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r728038 - /activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h
Date Fri, 19 Dec 2008 14:50:47 GMT
Author: tabish
Date: Fri Dec 19 06:50:47 2008
New Revision: 728038

URL: http://svn.apache.org/viewvc?rev=728038&view=rev
Log:
Add a small delay in the shutdown sequence to allow all acks to make it back to the Broker.

Modified:
    activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h

Modified: activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h?rev=728038&r1=728037&r2=728038&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h (original)
+++ activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h Fri Dec
19 06:50:47 2008
@@ -26,6 +26,8 @@
 #include <activemq/util/CMSProvider.h>
 #include <activemq/util/IntegrationCommon.h>
 
+#include <decaf/lang/Thread.h>
+
 namespace activemq {
 namespace test {
 
@@ -50,7 +52,12 @@
             cmsProvider.reset( new util::CMSProvider( getBrokerURL() ) );
         };
 
-        virtual void tearDown() { cmsProvider.reset( NULL ); };
+        virtual void tearDown() {
+            // Wait a small period of time to allow the messages to all get
+            // processed.
+            decaf::lang::Thread::sleep( 50 );
+            cmsProvider.reset( NULL );
+        };
 
     };
 



Mime
View raw message