fix: define stub consumer/producer methods before app boots (#7)

Author: rahulbile

lib/index.js

@@ -22,7 +22,7 @@ module.exports = function loopbackComponentMq(app, config) {
   // Get a reference to the created model and set up the topology
   const Queue = app.models.Queue
 
-  RabbitTopology.setupTopology(Queue)
+  RabbitTopology.stubQueueMethod(Queue)
 
   // Wait the app to be booted
   app.once('booted', () => {
@@ -36,6 +36,7 @@ module.exports = function loopbackComponentMq(app, config) {
     if (ds && dsOptions) {
       Queue.rabbit = new Rabbit(dsOptions)
       RabbitTopology.setupQueues(Queue)
+      RabbitTopology.setupTopology(Queue)
     }
 
   })

lib/rabbit-topology.js

@@ -90,11 +90,45 @@ module.exports = function rabbitTopology() {
     })
   }
 
+  function stubQueueMethod(StubmodelModel) {
+    // Loop through all the defined queues
+    _.forEach(StubmodelModel.topology, handlers => {
+
+
+      // Setup the consumer of this queue
+      if (handlers.consumer) {
+        const modelName = handlers.consumer.model
+        const methodName = handlers.consumer.method
+        const Model = StubmodelModel.app.models[modelName]
+
+        // Log if the method does not exists yet
+        Model[methodName] = function stubQueueConsumer() {
+          debug(`${modelName}.${methodName} is not initialised yet`)
+        }
+      }
+
+      // Setup the producers of this queue
+      if (handlers.producer) {
+        const modelName = handlers.producer.model
+        const methodName = handlers.producer.method
+        const Model = StubmodelModel.app.models[modelName]
+
+        // Log if the method does not exists yet
+        Model[methodName] = function stubQueueProducer() {
+          debug(`${modelName}.${methodName} is not initialised yet`)
+        }
+      }
+
+    })
+
+  }
+
   return {
     setupQueue,
     setupQueues,
     setupTopology,
     setupQueueProducer,
     setupQueueConsumer,
+    stubQueueMethod,
   }
 }