Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
RicoSuter committed Aug 18, 2019
1 parent 6e47df7 commit 27c77dc
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions README.md
Expand Up @@ -23,30 +23,30 @@ To use the `IMessageReceiver` in a simple command line application ([.NET Generi
```CSharp
public class MyBackgroundService : BackgroundService
{
private readonly IMessageReceiver<MyMessage> _messageReceiver;
private readonly IMessageReceiver _messageReceiver;
private readonly ILogger _logger;

public MyBackgroundService(IMessageReceiver<MyMessage> messageReceiver, ILogger logger)
public MyBackgroundService(IMessageReceiver messageReceiver, ILogger logger)
{
_messageReceiver = messageReceiver;
_logger = logger;
}

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
await _messageReceiver.ListenAndDeserializeJsonAsync(async (messages, ct) =>
await _messageReceiver.ListenAsync(async (messages, ct) =>
{
foreach (var message in messages)
{
try
{

// TODO: Process message
await _messageReceiver.ConfirmAsync(message, ct);
}
catch (Exception e)
{
_logger.LogWarning(e, $"Error while processing {nameof(MyMessage)} message.");
_logger.LogError(e, $"Error while processing {nameof(MyMessage)} message.");
await _messageReceiver.RejectAsync(message, ct);
}
}
Expand Down

0 comments on commit 27c77dc

Please sign in to comment.