diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-05-05 12:26:29 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-05-05 12:26:29 +0000 |
| commit | 63653afbd2e8f6db2a3a9ff90707476bbb817ea1 (patch) | |
| tree | 2ef7f9a504e10431fa9d9c02f8c99f65e143220f | |
| parent | d79a22bba1c8bffcdd0129a7e72d4d692351915c (diff) | |
| download | qpid-python-63653afbd2e8f6db2a3a9ff90707476bbb817ea1.tar.gz | |
Check if consumer is closed and dont reclose it
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.x@653447 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | dotnet/Qpid.Client/Client/BasicMessageConsumer.cs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs index e88cf8f04c..6fee316cb4 100644 --- a/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs +++ b/dotnet/Qpid.Client/Client/BasicMessageConsumer.cs @@ -266,7 +266,11 @@ namespace Apache.Qpid.Client public override void Close() { - // FIXME: Don't we need FailoverSupport here (as we have SyncWrite). i.e. rather than just locking FailOverMutex + if (_closed == CLOSED) + { + return; + } + // FIXME: Don't we need FailoverSupport here (as we have SyncWrite). i.e. rather than just locking FailOverMutex lock (_channel.Connection.FailoverMutex) { lock (_closingLock) |