fix: make error processing asynchronous (#311)

Signed-off-by: Ruben Romero Montes <rromerom@redhat.com>
RHEcosystemAppEng · Mar 14, 2024 · 9fbcc73 · 9fbcc73
1 parent 15c5ded
commit 9fbcc73
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/redhat/exhort/integration/backend/ExhortIntegration.java b/src/main/java/com/redhat/exhort/integration/backend/ExhortIntegration.java
@@ -256,16 +256,16 @@ public void configure() {
       .routeId("analyticsTrackAnalysis")
       .process(analytics::trackAnalysis);
 
-    from(seda("processFailedRequests"))
+    from(seda("processFailedRequests")).setExchangePattern(ExchangePattern.InOnly)
       .routeId("processFailedRequests")
-      .setHeader(Constants.EXHORT_REQUEST_ID_HEADER, exchangeProperty(Constants.EXHORT_REQUEST_ID_HEADER))
       .process(monitoringProcessor::processServerError);
 
     from(direct("processInternalError"))
       .routeId("processInternalError")
       .log(LoggingLevel.ERROR, "${exception.stacktrace}")
-      .to(seda("processFailedRequests"))
+      .to(seda("processFailedRequests").waitForTaskToComplete(WaitForTaskToComplete.Never))
       .setBody().simple("${exception.message}")
+      .setHeader(Constants.EXHORT_REQUEST_ID_HEADER, exchangeProperty(Constants.EXHORT_REQUEST_ID_HEADER))
       .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Status.INTERNAL_SERVER_ERROR.getStatusCode()))
       .setHeader(Exchange.CONTENT_TYPE, constant(MediaType.TEXT_PLAIN));