fixup

Author: lukebakken

RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

@@ -264,7 +264,7 @@ void OnOpened(Amqp.IConnection connection, Open open1)
             catch (Exception ex)
             {
                 throw new ConnectionException(
-                    $"{ToString()}  connection failed.", ex);
+                    $"{ToString()} connection failed.", ex);
             }
 
             if (_nativeConnection.IsClosed)
@@ -412,11 +412,12 @@ await _recordingTopologyListener.Accept(visitor)
                     }
 
                     OnNewStatus(State.Open, null);
-                    // after the connection is recovered we have to reconnect all the publishers and consumers
 
+                    // after the connection is recovered we have to reconnect all the publishers and consumers
                     try
                     {
-                        await ReconnectEntitiesAsync().ConfigureAwait(false);
+                        await ReconnectEntitiesAsync()
+                            .ConfigureAwait(false);
                     }
                     catch (Exception e)
                     {
@@ -434,11 +435,14 @@ await _recordingTopologyListener.Accept(visitor)
             }
             finally
             {
-                // TODO it is odd to have to add this check
-                if (false == _disposed)
+                // TODO it is odd to have to add this code, figure out why
+                try
                 {
                     _semaphoreClose.Release();
                 }
+                catch (ObjectDisposedException)
+                {
+                }
             }
         };
     }