code: func HandleScheduleQueueItem(db sqlx.Ext, qi storage.MulticastQueueItem) error {
  	ctx := multicastContext{
  		DB:                 db,
  		MulticastQueueItem: qi,
  	}
  
  	for _, t := range multicastTasks {
  		if err := t(&ctx); err != nil {
  			if err == errAbort {
  				return nil
  			}
  			return err
  		}
  	}
  
  	return nil
  }
docs: // HandleScheduleQueueItem handles the scheduling of the given queue-item.