Add assert option

README.md

@@ -453,6 +453,8 @@ To set up your development environment:
 [Back to top](#table-of-contents)
 
 ## Change History
+* v1.6.0 (2018-10-31)
+    * Add assert option in Exchange and Queue decorator to allow to disable assert during bootstrap
 * v1.5.1 (2018-09-24)
     * Fix reconnection error: use once instad of on and rebind event correctly
 * v1.5.0 (2018-08-24)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@hapiness/rabbitmq",
-  "version": "1.5.2",
+  "version": "1.6.0",
   "description": "Hapiness module for rabbitmq",
   "main": "commonjs/index.js",
   "types": "index.d.ts",

src/module/decorators/exchange.decorator.ts

@@ -8,11 +8,13 @@ export interface ExchangeDecoratorInterface {
     options?: Options.AssertExchange;
     channel?: ChannelOptions;
     providers?: Array<Type<any> | any>;
+    assert?: boolean;
 }
 export const Exchange: CoreDecorator<ExchangeDecoratorInterface> = createDecorator<ExchangeDecoratorInterface>('Exchange', {
     name: undefined,
     type: undefined,
     options: undefined,
     channel: undefined,
     providers: [],
+    assert: true,
 });

src/module/decorators/queue.decorator.ts

@@ -10,6 +10,7 @@ export interface QueueDecoratorInterface {
     channel?: ChannelOptions;
     force_json_decode?: boolean;
     providers?: Array<Type<any> | any>;
+    assert?: boolean;
 }
 export const Queue: CoreDecorator<QueueDecoratorInterface> = createDecorator<QueueDecoratorInterface>('Queue', {
     name: undefined,
@@ -18,4 +19,5 @@ export const Queue: CoreDecorator<QueueDecoratorInterface> = createDecorator<Que
     channel: undefined,
     force_json_decode: false,
     providers: [],
+    assert: true,
 });

src/module/extension/build-exchange.ts

@@ -17,7 +17,7 @@ export default function buildExchanges(modules: CoreModule[], connection: Connec
             .map(instance => ({ instance, _module, metadata })))
         .flatMap(({ instance, _module, metadata }) => {
             const exchange = new ExchangeManager(connection.defaultChannel, new ExchangeWrapper(instance, metadata.data));
-            return exchange.assert();
+            return metadata.data.assert ? exchange.assert() : Observable.of(exchange);
         })
         .toArray();
 }

src/module/extension/build-queues.ts

@@ -30,7 +30,8 @@ export default function buildQueues(
                 Observable.of({ instance, metadata, channel: connection.defaultChannelManager, _module }))
         .mergeMap(({ instance, metadata, channel, _module }) => {
             const queue = new QueueManager(channel, new QueueWrapper(instance, metadata.data));
-            return Observable.forkJoin(queue.assert(), Observable.of(metadata), Observable.of(_module));
+            return Observable
+                .forkJoin(metadata.data.assert ? queue.assert() : Observable.of(queue), Observable.of(metadata), Observable.of(_module));
         })
         // Bind queue
         .mergeMap(([queue, metadata, _module]) => {