Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
Co-authored-by: Sebastian <[email protected]>
  • Loading branch information
tomwwinter and sleidig authored Aug 13, 2024
1 parent ce56cba commit 906f791
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ class DefaultReportDocumentChangeEventConsumer(
@RabbitListener(
queues = [ReportQueueConfiguration.DOCUMENT_CHANGES_REPORT_QUEUE],
ackMode = "MANUAL",
// avoid concurrent processing so that we do not trigger multiple calculations for same data unnecessarily
concurrency = "1-1",
batch = "1"
)
Expand Down Expand Up @@ -99,7 +100,7 @@ class DefaultReportDocumentChangeEventConsumer(

return Mono.error {
throw AmqpRejectAndDontRequeueException(
"[NO_USECASE_CONFIGURED] Could not found matching use case for: ${type.qualifiedName}",
"[NO_USECASE_CONFIGURED] Could not find matching use case for: ${type.qualifiedName}",
)
}
}
Expand Down

0 comments on commit 906f791

Please sign in to comment.