Skip to content

Commit b75284f

Browse files
committed
remove unsed code
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent cb60240 commit b75284f

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

RabbitMQ.Stream.Client/AbstractEntity.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,7 @@ protected async Task<ResponseCode> Shutdown(EntityCommonConfig config, bool igno
9292
return result;
9393
}
9494

95-
var closed = await _client.MaybeClose($"closing: {EntityId}",
96-
GetStream(), config.Pool)
95+
var closed = await _client.MaybeClose($"closing: {EntityId}", config.Pool)
9796
.ConfigureAwait(false);
9897
ClientExceptions.MaybeThrowException(closed.ResponseCode, $"_client-close-Entity: {EntityId}");
9998
Logger.LogDebug("{EntityInfo} is closed", DumpEntityConfiguration());

RabbitMQ.Stream.Client/Client.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -813,7 +813,7 @@ public async Task<CloseResponse> Close(string reason)
813813
// Release will decrement the active ids for the connection
814814
// if the active ids are 0 the connection will be closed
815815

816-
internal async Task<CloseResponse> MaybeClose(string reason, string stream, ConnectionsPool pool)
816+
internal async Task<CloseResponse> MaybeClose(string reason, ConnectionsPool pool)
817817
{
818818
await _poolSemaphore.WaitAsync().ConfigureAwait(false);
819819
try

0 commit comments

Comments
 (0)