ConsumeChannel.prototype.stop = function(cb) {
  const self = this;

  this._consumeQueue.cancelConsume(function(err) {
    /* istanbul ignore if */