Changed source type in Listen decorator to Source to support filters.

Fixes team-supercharge#49.
solidhtp · Oct 6, 2021 · 8372209 · 8372209
1 parent 8205012
commit 8372209
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/decorator/listen/listen.decorator.ts b/src/decorator/listen/listen.decorator.ts
@@ -3,10 +3,11 @@ import { AMQP_DEFAULT_CONNECTION_TOKEN, QUEUE_LISTEN_METADATA_KEY } from '../../
 
 import { ListenerMetadata } from '../../domain';
 import { ListenOptions } from '../../interface';
+import { Source } from 'rhea-promise';
 
 interface ListenOverload {
-  (source: string, connection?: string): MethodDecorator;
-  <T>(source: string, options: ListenOptions<T>, connection?: string): MethodDecorator;
+  (source: string | Source, connection?: string): MethodDecorator;
+  <T>(source: string | Source, options: ListenOptions<T>, connection?: string): MethodDecorator;
 }
 
 /**
@@ -27,7 +28,7 @@ interface ListenOverload {
  * @public
  */
 export const Listen: ListenOverload = <T>(
-  source: string,
+  source: string | Source,
   listenOptions?: ListenOptions<T> | string,
   connectionName?: string,
 ): MethodDecorator => {