fixup! Propagate headers for RabbitMQ handlers

Workable · Oct 3, 2023 · 9d886f8 · 9d886f8
1 parent 3b40e03
commit 9d886f8
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/initializers/rabbitmq/index.ts b/src/initializers/rabbitmq/index.ts
@@ -112,12 +112,12 @@ export const close = async () => {
   }
 };
 
-function methodCreator(originalSendToQueue, paramNum, config) {
+function methodCreator(originalSendToQueue, propertiesArgIndex, config) {
   return function method(...args: any) {
-    let properties = args[paramNum - 1];
+    let properties = args[propertiesArgIndex - 1];
     if (!properties) {
       properties = {};
-      args[paramNum - 1] = properties;
+      args[propertiesArgIndex - 1] = properties;
     }
 
     const traceHeaderName = config.traceHeaderName.toLowerCase();