diff options
| author | Steven Shaw <steshaw@apache.org> | 2006-11-28 20:29:56 +0000 |
|---|---|---|
| committer | Steven Shaw <steshaw@apache.org> | 2006-11-28 20:29:56 +0000 |
| commit | c4fac88720bbfbaacbd821596d46e8715a161639 (patch) | |
| tree | de07d81c5be72af718b637bd8095f55ae4e3cee5 /dotnet/Qpid.Client/Client/BasicMessageConsumer.cs | |
| parent | a204a5602d5c8569a3046d424d7d3dc506fcec22 (diff) | |
| download | qpid-python-c4fac88720bbfbaacbd821596d46e8715a161639.tar.gz | |
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
Diffstat (limited to 'dotnet/Qpid.Client/Client/BasicMessageConsumer.cs')
| -rw-r--r-- | dotnet/Qpid.Client/Client/BasicMessageConsumer.cs | 1 |
1 files changed, 1 insertions, 0 deletions
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) |