fix(messaging): removed reference to AMQP Options type

marblejs · Sep 6, 2020 · 0e751cf · 0e751cf
1 parent 5da9fab
commit 0e751cf
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/packages/messaging/src/transport/strategies/amqp.strategy.interface.ts b/packages/messaging/src/transport/strategies/amqp.strategy.interface.ts
@@ -1,4 +1,3 @@
-import { Options } from 'amqplib';
 import { NamedError } from '@marblejs/core/dist/+internal/utils';
 import { Transport } from '../transport.interface';
 
@@ -10,7 +9,18 @@ export interface AmqpStrategy {
 export interface AmqpStrategyOptions {
   host: string;
   queue: string;
-  queueOptions?: Options.AssertQueue;
+  queueOptions?: {
+    exclusive?: boolean;
+    durable?: boolean;
+    autoDelete?: boolean;
+    arguments?: any;
+    messageTtl?: number;
+    expires?: number;
+    deadLetterExchange?: string;
+    deadLetterRoutingKey?: string;
+    maxLength?: number;
+    maxPriority?: number;
+  };
   prefetchCount?: number;
   expectAck?: boolean;
   timeout?: number;