code: function consume(socket, data) {
    if (_.isUndefined(data.routingKey) || !_.isString(data.routingKey)) {
      // invalid consume message
      return;
    }
  
    // sanitize the routing key
    data.routingKey = sanitizeRoutingKey(data.routingKey);
  
    this.consumer.consume(socket, data);
  }
docs: Private functions