docs: function _subscribeToChannelEvents(channel,
      { exchangeName, queueName, channelPrefetch, workerName }) {
      channel.on('error', err => {
        logger.error(
          { err, exchangeName, queueName, channelPrefetch, workerName },
          '[AMQP] channel error'
        );
      });
      channel.on('close', () => {
        logger.info(
          { exchangeName, queueName, channelPrefetch, workerName },
          '[AMQP] channel closed'
        );
        // Remove this channel because is closed
        workerChannels.delete(channel);
        workers.close();
      });
    }