You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2008/12/19 15:50:47 UTC
svn commit: r728038 -
/activemq/activemq-cpp/trunk/src/test-integration/activemq/test/CMSTestFixture.h
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 );
+ };
};