code: func MulticastQueueSchedulerLoop() {
  	for {
  		log.Debug("running multicast scheduler batch")
  		if err := ScheduleMulticastQueueBatch(schedulerBatchSize); err != nil {
  			log.WithError(err).Error("multicast scheduler error")
  		}
  		time.Sleep(schedulerInterval)
  	}
  }
docs: // MulticastQueueSchedulerLoop starts an infinit loop calling the multicast
  // scheduler loop.