feat(rabbitmq): message expiration property (#373)

adds ability to set message expiration when publishing messages fixes #270
golevelup · Jan 23, 2022 · 08e2014 · 08e2014
1 parent 754e1db
commit 08e2014
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts
@@ -264,6 +264,7 @@ export class AmqpConnection {
         replyTo: DIRECT_REPLY_QUEUE,
         correlationId,
         headers: requestOptions.headers,
+        expiration: requestOptions.expiration,
       }
     );
 
@@ -385,9 +386,13 @@ export class AmqpConnection {
           return;
         }
 
-        const { replyTo, correlationId, headers } = msg.properties;
+        const { replyTo, correlationId, expiration, headers } = msg.properties;
         if (replyTo) {
-          await this.publish('', replyTo, response, { correlationId, headers });
+          await this.publish('', replyTo, response, {
+            correlationId,
+            expiration,
+            headers,
+          });
         }
         channel.ack(msg);
       } catch (e) {

diff --git a/packages/rabbitmq/src/rabbitmq.interfaces.ts b/packages/rabbitmq/src/rabbitmq.interfaces.ts
@@ -24,6 +24,7 @@ export interface RequestOptions {
   timeout?: number;
   payload?: any;
   headers?: any;
+  expiration?: string | number;
 }
 
 export interface QueueOptions {