Author: jgomes
Date: Tue Aug  5 17:51:19 2008
New Revision: 683066

URL: http://svn.apache.org/viewvc?rev=683066&view=rev
Log:
Implemented ISession.DeleteDurableConsumer().
Fixes [AMQNET-92]. (See https://issues.apache.org/activemq/browse/AMQNET-92)

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/InheritedTests.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=683066&r1=683065&r2=683066&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Tue Aug  5 17:51:19 2008
@@ -291,9 +291,17 @@
 
 		public void DeleteDurableConsumer(string name)
 		{
-			ConsumerInfo command = CreateConsumerInfo(null, String.Empty);
-			command.SubscriptionName = name;
-			Connection.SyncRequest(command, Connection.ITransport.RequestTimeout);
+			DeleteDurableConsumer(name, Connection.ITransport.RequestTimeout);
+		}
+
+		public void DeleteDurableConsumer(string name, TimeSpan requestTimeout)
+		{
+			RemoveSubscriptionInfo command = new RemoveSubscriptionInfo();
+			command.ConnectionId = Connection.ConnectionId;
+			command.ClientId = Connection.ClientId;
+			command.SubcriptionName = name;
+
+			Connection.SyncRequest(command, requestTimeout);
 		}
 
 		public IQueue GetQueue(string name)

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/InheritedTests.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/InheritedTests.cs?rev=683066&r1=683065&r2=683066&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/InheritedTests.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/InheritedTests.cs Tue Aug  5 17:51:19 2008
@@ -19,6 +19,11 @@
 namespace Apache.NMS.ActiveMQ.Test
 {
 	[TestFixture]
+	public class AsyncConsumeTest : Apache.NMS.Test.AsyncConsumeTest
+	{
+	}
+
+	[TestFixture]
 	public class BadConsumeTest : Apache.NMS.Test.BadConsumeTest
 	{
 	}