fix(use): throw an error if a plugin does not provide a function

noodlefrenzy · Nov 18, 2016 · e50566a · e50566a
1 parent 5455179
commit e50566a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -40,6 +40,10 @@ module.exports = {
    * Syntactic sugar for pluggable amqp10 Client behaviors
    */
   use: function(plugin) {
+    if (typeof plugin !== 'function') {
+      throw new Error('Plugin is not a function');
+    }
+
     plugin(Client);
   }
 };
diff --git a/test/unit/client.test.js b/test/unit/client.test.js
@@ -45,6 +45,10 @@ describe('Client', function() {
       var client = new amqp.Client();
       client.thing();
     });
+
+    it('should throw an error if provided a plugin that is not a function', function() {
+      expect(function() { amqp.use({}); }).to.throw('Plugin is not a function');
+    });
   });
 
   describe('#connect()', function() {