avoid to call the

DeleteEntityFromTheServer when the socket is closed

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

RabbitMQ.Stream.Client/AbstractEntity.cs

@@ -93,8 +93,8 @@ protected async Task<ResponseCode> Shutdown(EntityCommonConfig config, bool igno
             }
 
             UpdateStatusToClosed();
-
             // we can ignore if the ignoreIfAlreadyDeleted or the socket is already closed
+            // DeleteEntityFromTheServer must be called anyway because it cleans the internal lists
             var ignore = ignoreIfAlreadyDeleted || _client.IsClosed;
             var result = await DeleteEntityFromTheServer(ignore).ConfigureAwait(false);
 

RabbitMQ.Stream.Client/RawProducer.cs

@@ -392,8 +392,11 @@ protected override async Task<ResponseCode> DeleteEntityFromTheServer(bool ignor
                 // in this case we reduce the waiting time
                 // the producer could be removed because of stream deleted 
                 // so it is not necessary to wait.
+                // we can ignore if the ignoreIfAlreadyDeleted or the socket is already closed
+                // DeletePublisher must be called anyway because it cleans the internal lists
+                var ignore = ignoreIfAlreadyDeleted || _client.IsClosed;
                 var closeResponse =
-                    await _client.DeletePublisher(EntityId, ignoreIfAlreadyDeleted).ConfigureAwait(false);
+                    await _client.DeletePublisher(EntityId, ignore).ConfigureAwait(false);
                 return closeResponse.ResponseCode;
             }
             catch (Exception e)