errors.InvalidSubjectError = function(subject) {
  errors.BaseError.call(this, 'Invalid subject: ' + subject);
  this.name = 'AmqpInvalidSubjectError';
};