You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jg...@apache.org on 2008/08/06 02:51:19 UTC
svn commit: r683066 - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src:
main/csharp/Session.cs test/csharp/InheritedTests.cs
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
{
}