Skip to content

Commit 20d04d9

Browse files
committed
Rename field
1 parent 3dfe05d commit 20d04d9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ sealed class MessagePump : IPushMessages, IDisposable
3333

3434
// Start
3535
int maxConcurrency;
36-
long numberOfExecutingReceives;
36+
long numberOfMessagesBeingProcessed;
3737
CancellationTokenSource messageProcessing;
3838
IConnection connection;
3939
AsyncEventingBasicConsumer consumer;
@@ -113,7 +113,7 @@ public async Task Stop()
113113
consumer.Received -= Consumer_Received;
114114
messageProcessing.Cancel();
115115

116-
while (Interlocked.Read(ref numberOfExecutingReceives) > 0)
116+
while (Interlocked.Read(ref numberOfMessagesBeingProcessed) > 0)
117117
{
118118
await Task.Delay(50).ConfigureAwait(false);
119119
}
@@ -157,7 +157,7 @@ async Task Consumer_Received(object sender, BasicDeliverEventArgs eventArgs)
157157
return;
158158
}
159159

160-
Interlocked.Increment(ref numberOfExecutingReceives);
160+
Interlocked.Increment(ref numberOfMessagesBeingProcessed);
161161

162162
try
163163
{
@@ -170,7 +170,7 @@ async Task Consumer_Received(object sender, BasicDeliverEventArgs eventArgs)
170170
}
171171
finally
172172
{
173-
Interlocked.Decrement(ref numberOfExecutingReceives);
173+
Interlocked.Decrement(ref numberOfMessagesBeingProcessed);
174174
}
175175
}
176176

0 commit comments

Comments
 (0)