Skip to content

Commit f9c9594

Browse files
committed
revert consumerTag
1 parent 622afa2 commit f9c9594

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcher.cs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,22 +25,23 @@ protected override async Task ProcessChannelAsync()
2525
try
2626
{
2727
IBasicConsumer consumer = work.Consumer;
28+
string consumerTag = work.ConsumerTag!;
2829
switch (work.WorkType)
2930
{
3031
case WorkType.Deliver:
3132
await consumer.HandleBasicDeliverAsync(
32-
work.ConsumerTag!, work.DeliveryTag, work.Redelivered,
33+
consumerTag, work.DeliveryTag, work.Redelivered,
3334
work.Exchange!, work.RoutingKey!, work.BasicProperties!, work.Body.Memory)
3435
.ConfigureAwait(false);
3536
break;
3637
case WorkType.Cancel:
37-
consumer.HandleBasicCancel(work.ConsumerTag!);
38+
consumer.HandleBasicCancel(consumerTag);
3839
break;
3940
case WorkType.CancelOk:
40-
consumer.HandleBasicCancelOk(work.ConsumerTag!);
41+
consumer.HandleBasicCancelOk(consumerTag);
4142
break;
4243
case WorkType.ConsumeOk:
43-
consumer.HandleBasicConsumeOk(work.ConsumerTag!);
44+
consumer.HandleBasicConsumeOk(consumerTag);
4445
break;
4546
case WorkType.Shutdown:
4647
consumer.HandleChannelShutdown(_channel, work.Reason!);

0 commit comments

Comments
 (0)