Remove hooks from configuration object.

Since the configuration object changes every time the connection is constructed, it doesn't make sense to have the hooks there.

README.md

@@ -181,11 +181,6 @@ const arnavmq = require('arnavmq')({
    * * params - An optional object containing extra parameters that can provide extra context for the event.
    */
   logger: utils.emptyLogger,
-
-  /**
-   * Configure hooks to register on the connection, consumer and producer.
-   */
-  hooks: undefined,
 });
 ```
 

src/modules/consumer.js

@@ -10,7 +10,7 @@ class Consumer {
   constructor(connection) {
     this._connection = connection;
     this._configuration = this._connection.config;
-    this.hooks = new ConsumerHooks(this._configuration.hooks && this._configuration.hooks.consumer);
+    this.hooks = new ConsumerHooks();
   }
 
   set connection(value) {

src/modules/hooks/connection_hooks.js

@@ -1,20 +1,6 @@
 const BaseHooks = require('./base_hooks');
 
 class ConnectionHooks extends BaseHooks {
-  constructor(hooks) {
-    super();
-
-    if (!hooks) {
-      return;
-    }
-    if (hooks.afterConnect) {
-      this.afterConnect(hooks.afterConnect);
-    }
-    if (hooks.beforeConnect) {
-      this.beforeConnect(hooks.beforeConnect);
-    }
-  }
-
   /**
    * Registers callback/callbacks to be invoked before creating a connection to rabbitmq.
    * The callback is invoked with 'this' set to the connection wrapper instance creating the connection, and a single "payload" argument of the following shape:

src/modules/hooks/consumer_hooks.js

@@ -1,26 +1,6 @@
 const BaseHooks = require('./base_hooks');
 
 class ConsumerHooks extends BaseHooks {
-  constructor(hooks) {
-    super();
-
-    if (!hooks) {
-      return;
-    }
-    if (hooks.beforeProcessMessage) {
-      this.beforeProcessMessage(hooks.beforeProcessMessage);
-    }
-    if (hooks.afterProcessMessage) {
-      this.afterProcessMessage(hooks.afterProcessMessage);
-    }
-    if (hooks.beforeRpcReply) {
-      this.beforeRpcReply(hooks.beforeRpcReply);
-    }
-    if (hooks.afterRpcReply) {
-      this.afterRpcReply(hooks.afterRpcReply);
-    }
-  }
-
   /**
    * Registers callback/callbacks to be invoked before consumer starts processing a received message.
    * The callback is invoked with 'this' set to the consumer instance, and a single "payload" argument of the following shape:

src/modules/hooks/producer_hooks.js

@@ -1,20 +1,6 @@
 const BaseHooks = require('./base_hooks');
 
 class ProducerHooks extends BaseHooks {
-  constructor(hooks) {
-    super();
-
-    if (!hooks) {
-      return;
-    }
-    if (hooks.beforePublish) {
-      this.beforePublish(hooks.beforePublish);
-    }
-    if (hooks.afterPublish) {
-      this.afterPublish(hooks.afterPublish);
-    }
-  }
-
   /**
    * Registers callback/callbacks to be invoked before producer publishes a message.
    * The callback is invoked with 'this' set to the producer instance, and a single "payload" argument of the following shape:

src/modules/producer.js

@@ -24,8 +24,7 @@ class ProducerError extends Error {
 class Producer {
   constructor(connection) {
     this._connection = connection;
-    const { hooks } = this._connection.config;
-    this.hooks = new ProducerHooks(hooks && hooks.producer);
+    this.hooks = new ProducerHooks();
 
     /**
      * Map of rpc queues