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 04bca53 commit 0cd705eCopy full SHA for 0cd705e
projects/RabbitMQ.Client/client/impl/Work.cs
@@ -1,5 +1,4 @@
1
-using System;
2
-using System.Threading.Tasks;
+using System.Threading.Tasks;
3
4
namespace RabbitMQ.Client.Impl
5
{
@@ -12,17 +11,9 @@ protected Work(IBasicConsumer consumer)
12
11
_asyncConsumer = (IAsyncBasicConsumer)consumer;
13
}
14
15
- public async Task Execute(ModelBase model)
+ public Task Execute(ModelBase model)
16
17
- try
18
- {
19
- await Task.Yield();
20
- await Execute(model, _asyncConsumer).ConfigureAwait(false);
21
- }
22
- catch (Exception)
23
24
- // intentionally caught
25
+ return Execute(model, _asyncConsumer);
26
27
28
protected abstract Task Execute(ModelBase model, IAsyncBasicConsumer consumer);
0 commit comments