FranklinWH-Toolbox/service/task/queue/taskQueue.go

package taskQueue

import (
	"fwh-toolbox-server/config"
	task_core "fwh-toolbox-server/task/core"
	"fwh-toolbox-server/task/queue/dataDownloadQueue"
	"fwh-toolbox-server/task/queue/faultRecordQueue"
	"fwh-toolbox-server/task/queue/fwhQueue"
	"fwh-toolbox-server/task/queue/simCardQueue"
)

func InitTaskQueue(tc *task_core.TaskCore, appConfig *config.AppConfig) {
	if tc == nil {
		panic("InitTaskQueue failed, TaskCore is nil.")
	}

	fwhQueue.InitFwhTaskQueue(tc)
	dataDownloadQueue.Init(tc)
	faultRecordQueue.Init(tc)
	simCardQueue.InitSimCardTaskQueue(tc, appConfig)
}