feat: pass the full message into the consumer as second param

Author: beeman

lib/mixins/message-queue.js

@@ -29,7 +29,7 @@ module.exports = function messageQueueMixin(Model, options) {
         const RabbitMQ = loopback.getModel('RabbitMQ')
 
         try {
-          return Model[name](msg.body)
+          return Model[name](msg.body, msg)
             .then(() => {
               debug('consumer %s ran successfully for model %s. key: %o',
                 name, Model.modelName, msg.fields.routingKey)

test/mixin.test.js

@@ -58,8 +58,10 @@ describe('Mixin', function() {
       expect(app.models.Client.consumeNewItems.calledOnce).to.be.true()
     })
     it('should pass the message body to the consumer', function() {
-      expect(app.models.Client.consumeAllItems.calledWith('a message')).to.be.true()
-      expect(app.models.Client.consumeNewItems.calledWith('a message')).to.be.true()
+      expect(
+        app.models.Client.consumeAllItems.calledWithMatch('a message', { type: 'item.write.created' })).to.be.true()
+      expect(
+        app.models.Client.consumeNewItems.calledWithMatch('a message', { type: 'item.write.created' })).to.be.true()
     })
   })
 })