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.
2 parents c93144a + 0cd705e commit 7c9914aCopy full SHA for 7c9914a
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