Merge pull request #32 from BonnierNews/reject-with-correlation

Reject with correlationId
BonnierNews · Nov 10, 2023 · 8c931bf · 8c931bf
2 parents f3c2a41 + 2e96a4f
commit 8c931bf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/message-handler.js b/lib/message-handler.js
@@ -133,7 +133,7 @@ export default async function messageHandler(recipeMap, req, res) {
       case "resume":
         if (Number(resumedCount) >= maxResumeCount) {
           logger.error(`Message delayed for max amount ${maxResumeCount} of times`);
-          await rejectMessage({ ...message, error: `To many resume retries. Retries: ${resumedCount}` }, { key });
+          await rejectMessage({ ...message, error: `To many resume retries. Retries: ${resumedCount}` }, { key, correlationId, parentCorrelationId });
           return res.status(200).send();
         }
         if (!isValidDelay(result.delayMs)) {
@@ -168,7 +168,7 @@ export default async function messageHandler(recipeMap, req, res) {
   } catch (error) {
     if (error.rejected) {
       logger.error(`Rejected message with correlationId: ${correlationId}. Error: ${error}. Message: ${message}`);
-      await rejectMessage({ ...message, error: { message: error.extraMessage } }, { key });
+      await rejectMessage({ ...message, error: { message: error.extraMessage } }, { key, correlationId, parentCorrelationId });
       metrics.rejectedMessages.inc();
       return res.status(200).send();
     }