Skip to content

Commit 8ef7b11

Browse files
danielmarbachlukebakken
authored andcommitted
Switch AutorecoveringChannel to a simpler implementation
1 parent 770c7ee commit 8ef7b11

File tree

1 file changed

+1
-15
lines changed

1 file changed

+1
-15
lines changed

projects/RabbitMQ.Client/Impl/AutorecoveringChannel.cs

Lines changed: 1 addition & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -257,21 +257,7 @@ await _connection.DeleteRecordedChannelAsync(this,
257257
public override string ToString()
258258
=> InnerChannel.ToString();
259259

260-
public void Dispose()
261-
{
262-
if (_disposed)
263-
{
264-
return;
265-
}
266-
267-
if (IsOpen)
268-
{
269-
this.AbortAsync().GetAwaiter().GetResult();
270-
}
271-
272-
_recordedConsumerTags.Clear();
273-
_disposed = true;
274-
}
260+
public void Dispose() => DisposeAsync().AsTask().GetAwaiter().GetResult();
275261

276262
public async ValueTask DisposeAsync()
277263
{

0 commit comments

Comments
 (0)