From c4fac88720bbfbaacbd821596d46e8715a161639 Mon Sep 17 00:00:00 2001 From: Steven Shaw Date: Tue, 28 Nov 2006 20:29:56 +0000 Subject: Locked on FailoverMutex where necessary. Noted that AMQConnection.CloseSession and BasicMessageConsumer.Close both lock on FailoverMutex but do ProtocolWriter.SyncWrite which probably means that they need to do the FailoverSupport thing instead. If it's a problem, it exists also in the Java client. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480190 13f79535-47bb-0310-9956-ffa450edef68 --- dotnet/Qpid.Client/Client/BasicMessageConsumer.cs | 1 + 1 file changed, 1 insertion(+) (limited to 'dotnet/Qpid.Client/Client/BasicMessageConsumer.cs') diff --git a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs index 6ffa8d1d6a..f0603b6e8a 100644 --- a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs +++ b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs @@ -255,6 +255,7 @@ namespace Qpid.Client public override void Close() { + // FIXME: Don't we need FailoverSupport here (as we have SyncWrite). i.e. rather than just locking FailOverMutex lock (_channel.Connection.FailoverMutex) { lock (_closingLock) -- cgit v1.2.1