activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r830352 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
Date Tue, 27 Oct 2009 21:35:59 GMT
Author: tabish
Date: Tue Oct 27 21:35:59 2009
New Revision: 830352

URL: http://svn.apache.org/viewvc?rev=830352&view=rev
Log:
* VirtualTopicTest.cs: 

Adds some cleanup code to try and purge to Queue's so that repeated runs of the tests don't
fail.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs?rev=830352&r1=830351&r2=830352&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
Tue Oct 27 21:35:59 2009
@@ -16,6 +16,7 @@
  */
 
 using Apache.NMS.Util;
+using Apache.NMS.ActiveMQ;
 using NUnit.Framework;
 using NUnit.Framework.Extensions;
 using System.Threading;
@@ -90,6 +91,18 @@
 							session.Commit();
 						}
 					}
+
+                    // Give the Broker some time to remove the subscriptions.
+                    Thread.Sleep(2000);
+
+                    try
+                    {
+                        ((Session) session).DeleteDestination(session.GetQueue(CONSUMER_A_DESTINATION_NAME));
+                        ((Session) session).DeleteDestination(session.GetQueue(CONSUMER_B_DESTINATION_NAME));
+                    }
+                    catch
+                    {
+                    }
 				}
 			}
 		}
@@ -144,7 +157,19 @@
 							Thread.Sleep(250);
 						}
 					}
-				}
+                    
+                    // Give the Broker some time to remove the subscriptions.
+                    Thread.Sleep(2000);
+
+                    try
+                    {
+                        ((Session) session).DeleteDestination(session.GetQueue(CONSUMER_A_DESTINATION_NAME));
+                        ((Session) session).DeleteDestination(session.GetQueue(CONSUMER_B_DESTINATION_NAME));
+				    }
+                    catch
+                    {
+                    }
+                }
 			}
 		}
 



Mime
View raw message