def setup_queues
      logger.info 'setting up queues'
      vetted = @consumers.reject { |c| group_configured? && group_restricted?(c) }
      vetted.each do |c|
        setup_queue(c)
      end
    end
def setup_queues
      logger.info 'setting up queues'
      vetted = @consumers.reject { |c| group_configured? && group_restricted?(c) }
      vetted.each do |c|
        setup_queue(c)
      end
    end
Set up the queues for each of the worker's consumers.