fix(@rhtml/amqp): changed name to queue instead

r-html · Jan 10, 2025 · 8077bcd · 8077bcd
1 parent 96ea514
commit 8077bcd
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 8 deletions.
diff --git a/packages/amqp/src/amqp.constants.ts b/packages/amqp/src/amqp.constants.ts
@@ -23,4 +23,10 @@ export interface ModuleConfig extends Options.Connect {
   prefetchCount?: number;
 }
 
+export interface SubscribeDecoratorOptions {
+  queue: string;
+  consumeOptions?: Options.Consume;
+  assertOptions?: Options.AssertQueue;
+}
+
 export { Connection } from 'amqplib';
diff --git a/packages/amqp/src/decorators/subscribe.decorator.ts b/packages/amqp/src/decorators/subscribe.decorator.ts
@@ -1,18 +1,14 @@
 import { set } from '@rhtml/di';
-import { Options } from 'amqplib';
 
+import { SubscribeDecoratorOptions } from '../amqp.constants';
 import { AmqpService } from '../amqp.service';
 
 export const Subscribe =
   <T>({
-    name,
+    queue,
     consumeOptions = {},
     assertOptions = {},
-  }: {
-    name: string;
-    consumeOptions?: Options.Consume;
-    assertOptions?: Options.AssertQueue;
-  }) =>
+  }: SubscribeDecoratorOptions) =>
   (target: T, memberName: string) => {
     const OnInit =
       target['OnInit'] ||
@@ -23,7 +19,7 @@ export const Subscribe =
       value: async function (...args: unknown[]) {
         const amqpService = set(AmqpService);
         await amqpService.subscribe(
-          name,
+          queue,
           (msg, channel) => target[memberName].call(this, msg, channel),
           { assertOptions, consumeOptions }
         );