Skip to content

Commit f696571

Browse files
committed
Few tweaks
1 parent 52c757f commit f696571

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/NServiceBus.Transport.RabbitMQ/Connection/ChannelProvider.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,10 +84,10 @@ protected virtual void FireAndForget(Func<CancellationToken, Task> action, Cance
8484

8585
public async ValueTask<ConfirmsAwareChannel> GetPublishChannel(CancellationToken cancellationToken = default)
8686
{
87-
while (true)
87+
while (!cancellationToken.IsCancellationRequested)
8888
{
8989
var existing = Interlocked.CompareExchange(ref publishChannel, null, null);
90-
if (existing is not null && !existing.IsClosed)
90+
if (existing is { IsOpen: true })
9191
{
9292
return existing;
9393
}
@@ -114,7 +114,7 @@ public async ValueTask<ConfirmsAwareChannel> GetPublishChannel(CancellationToken
114114

115115
public ValueTask ReturnPublishChannel(ConfirmsAwareChannel channel, CancellationToken cancellationToken = default)
116116
{
117-
if (!channel.IsClosed)
117+
if (channel.IsOpen)
118118
{
119119
return ValueTask.CompletedTask;
120120
}

0 commit comments

Comments
 (0)