svn commit: r683066 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src: main/csharp/Session.cs test/csharp/InheritedTests.cs

[jgomes]

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
        {
        }