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 2014/08/12 17:58:42 UTC
svn commit: r1617515 - in
/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp:
MessageConsumer.cs MessageProducer.cs
Author: tabish
Date: Tue Aug 12 15:58:41 2014
New Revision: 1617515
URL: http://svn.apache.org/r1617515
Log:
https://issues.apache.org/jira/browse/AMQNET-454
apply: https://issues.apache.org/jira/secure/attachment/12661228/Apache.NMS.AMQP-28-close-qpid-sender-receiver.patch
Modified:
activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs
activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs
Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs?rev=1617515&r1=1617514&r2=1617515&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs Tue Aug 12 15:58:41 2014
@@ -116,6 +116,7 @@ namespace Apache.NMS.Amqp
{
try
{
+ qpidReceiver.Close();
qpidReceiver.Dispose();
qpidReceiver = null;
}
@@ -213,6 +214,7 @@ namespace Apache.NMS.Amqp
public void Close()
{
StopAsyncDelivery();
+ Stop();
}
protected virtual void StopAsyncDelivery()
Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs?rev=1617515&r1=1617514&r2=1617515&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs Tue Aug 12 15:58:41 2014
@@ -103,6 +103,7 @@ namespace Apache.NMS.Amqp
try
{
Tracer.DebugFormat("Stop Producer Id = " + ProducerId);
+ qpidSender.Close();
qpidSender.Dispose();
qpidSender = null;
}
@@ -168,6 +169,7 @@ namespace Apache.NMS.Amqp
public void Close()
{
+ Stop();
}
public void Dispose()