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 647da2e + 57b07bb commit 87933a6Copy full SHA for 87933a6
Aws/SQS/README.md
@@ -28,8 +28,9 @@ using (var materializer = system.Materializer())
28
// after we handled the message we need to take if off from the queue
29
return MessageAction.Delete(msg);
30
})
31
- .To(SqsAckSink.Grouped(client, QueueUrl)) // we delete messages in batches
32
- .Run(_materializer);
+ .ToMaterialized(SqsAckSink.Grouped(client, QueueUrl), Keep.Right)
+ // we delete messages in batches
33
+ .Run(materializer);
34
}
35
```
36
0 commit comments