Account for optional headers

nikitaeverywhere · Mar 13, 2024 · d98e132 · d98e132
1 parent 011581e
commit d98e132
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 14 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "node-message-bus",
-  "version": "3.3.3",
+  "version": "3.3.4",
   "description": "Minimalistic and complete AMQP message bus implementation",
   "main": "lib/index.js",
   "files": [
@@ -53,8 +53,8 @@
     "typescript": "^5.0.4"
   },
   "dependencies": {
-    "@types/amqplib": "^0.10.1",
-    "amqp-connection-manager": "^4.1.13",
+    "@types/amqplib": "^0.10.5",
+    "amqp-connection-manager": "^4.1.14",
     "amqplib": "^0.10.3"
   }
 }
diff --git a/src/consumer.ts b/src/consumer.ts
@@ -39,7 +39,7 @@ const backoffRetryMessage = async <DataType = any>({
   error?: Error;
 }) => {
   const currentBackoffSeconds =
-    parseInt(message.properties.headers[HEADER_NAME_EXP_BACKOFF_SEC]) || 0;
+    parseInt(message.properties.headers?.[HEADER_NAME_EXP_BACKOFF_SEC]) || 0;
   const nextBackoffSeconds = Math.min(
     MAX_EXP_BACKOFF,
     currentBackoffSeconds
@@ -156,8 +156,8 @@ export async function consumeMessages<Message extends IMessage>(
       }
 
       if (
-        message.properties.headers[HEADER_NAME_TARGET_QUEUE] &&
-        message.properties.headers[HEADER_NAME_TARGET_QUEUE] !== queueName
+        message.properties.headers?.[HEADER_NAME_TARGET_QUEUE] &&
+        message.properties.headers?.[HEADER_NAME_TARGET_QUEUE] !== queueName
       ) {
         log(
           `Skipping message "${message.fields.routingKey}" in queue "${queueName}" because it is intended for queue "${message.properties.headers[HEADER_NAME_TARGET_QUEUE]}" due to backoff.`