code: function() {
        if (this.subscriptions.length) {
          return Promise.map(this.subscriptions, (op) => {
            return op();
          })
          .then(() => {
            log.info(`Restarted ${this.subscriptions.length} subscriptions`);
          });
        }
        return Promise.resolve();
      }
docs: Restarts any subscriptions (called upon reconnect)