Skip to content

Commit 1c72f6e

Browse files
committed
Rebasing and fixing code to be uniform.
1 parent 4aceebe commit 1c72f6e

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

projects/RabbitMQ.Client/client/events/AsyncEventingBasicConsumer.cs

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -45,14 +45,10 @@ public override async Task HandleBasicConsumeOk(string consumerTag)
4545
}
4646

4747
///<summary>Fires the Received event.</summary>
48-
public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, ReadOnlyMemory<byte> body)
48+
public override async Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, ReadOnlyMemory<byte> body)
4949
{
50-
if (Received != null)
51-
{
52-
return Received.Invoke(this, new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body));
53-
}
54-
55-
return Task.CompletedTask;
50+
await base.HandleBasicDeliver(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);
51+
await (Received?.Invoke(this, new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body)) ?? Task.CompletedTask).ConfigureAwait(false);
5652
}
5753

5854
///<summary>Fires the Shutdown event.</summary>

0 commit comments

Comments
 (0)