Skip to content

Commit 22ea539

Browse files
committed
avoid to call the
DeleteEntityFromTheServer when the socket is closed Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent 62e8965 commit 22ea539

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

RabbitMQ.Stream.Client/AbstractEntity.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ protected async Task<ResponseCode> Shutdown(EntityCommonConfig config, bool igno
9393
}
9494

9595
UpdateStatusToClosed();
96-
96+
9797
// we can ignore if the ignoreIfAlreadyDeleted or the socket is already closed
9898
var ignore = ignoreIfAlreadyDeleted || _client.IsClosed;
9999
var result = await DeleteEntityFromTheServer(ignore).ConfigureAwait(false);

0 commit comments

Comments
 (0)