We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 136aa04 commit 0b4b623Copy full SHA for 0b4b623
Tests/Consumer/ConsumerMetricsTests.cs
@@ -37,10 +37,11 @@ public async Task RecordMessageDeliverySuccessAndDuration()
37
TaskCompletionSource<IMessage> tcs = new();
38
IConsumer consumer = await _connection.ConsumerBuilder()
39
.Queue(queueSpec)
40
- .MessageHandler(async (context, message) =>
+ .MessageHandler((context, message) =>
41
{
42
- await context.AcceptAsync();
+ context.Accept();
43
tcs.SetResult(message);
44
+ return Task.CompletedTask;
45
}
46
).BuildAndStartAsync();
47
0 commit comments