Function processSingleQueue

controller/notify.go:52–71

TODO: fix when product delete, goroutine leak

(queue *EventPool)

//TODO: fix when product delete, goroutine leak
func processSingleQueue(queue *EventPool) {
	duration := time.Millisecond * 100
	for {
		if queue.len() > GlobalConfig.SEND_MAX {
			duration = time.Microsecond * time.Duration(queue.len())
			if duration.Seconds() > float64(GlobalConfig.MAX_INTERVAL_WAIT_TIME) {
				duration = time.Second * time.Duration(GlobalConfig.MAX_INTERVAL_WAIT_TIME)
			}
		}
		if !queue.mute {
			event := queue.getQueueEvent()
			if queue.mute {
				queue.putQueueEvent(event)
			} else {
				go processSingleEvent(event)
			}
		}
		time.Sleep(duration)
	}
}

func processSingleEvent(event *QueueEvent) {
	switch event.status {