if (!_.isObject(this.app.config.pubsub.connection)) {
      return Promise.reject(
        new Error('Please provide an connection options')
      )
    }