connect() {
    amqp.connect(config.amqp.uri, config.amqp.options, (err, connection) => {
      if (err) {
        logger.error(err);
        return;