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 2010/01/12 01:19:41 UTC

svn commit: r898130 - /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs

Author: tabish
Date: Tue Jan 12 00:19:40 2010
New Revision: 898130

URL: http://svn.apache.org/viewvc?rev=898130&view=rev
Log:
Changes for Stomp and Durables

Modified:
    activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs?rev=898130&r1=898129&r2=898130&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/DurableTest.cs Tue Jan 12 00:19:40 2010
@@ -40,6 +40,11 @@
             this.postfix = new Random().Next();
         }
 
+        [TearDown]
+        public override void TearDown()
+        {
+        }
+
         [RowTest]
         [Row(AcknowledgementMode.AutoAcknowledge)]
         [Row(AcknowledgementMode.ClientAcknowledge)]
@@ -98,6 +103,9 @@
             }
             finally
             {
+                // Pause to allow Stomp to unregister at the broker.
+                Thread.Sleep(250);
+
                 UnregisterDurableConsumer(TEST_CLIENT_ID + ":" + this.postfix, CONSUMER_ID);
             }
         }
@@ -182,6 +190,9 @@
             }
             finally
             {
+                // Pause to allow Stomp to unregister at the broker.
+                Thread.Sleep(250);
+
                 UnregisterDurableConsumer(TEST_CLIENT_ID  + ":" + this.postfix, CONSUMER_ID);
             }
         }
@@ -204,6 +215,9 @@
             }
             finally
             {
+                // Pause to allow Stomp to unregister at the broker.
+                Thread.Sleep(250);
+                
                 UnregisterDurableConsumer(TEST_CLIENT_ID + ":" + this.postfix, CONSUMER_ID);
             }
         }