diff --git a/src/modules/crontask/processor/processor.go b/src/modules/crontask/processor/processor.go index afe440a1..cab305d3 100644 --- a/src/modules/crontask/processor/processor.go +++ b/src/modules/crontask/processor/processor.go @@ -5,6 +5,7 @@ import ( "ems.agt/src/modules/crontask/processor/backupEtcFromNE" "ems.agt/src/modules/crontask/processor/delExpiredNeBackup" "ems.agt/src/modules/crontask/processor/deleteExpiredRecord" + "ems.agt/src/modules/crontask/processor/genNeStateAlarm" "ems.agt/src/modules/crontask/processor/getStateFromNE" monitorsysresource "ems.agt/src/modules/crontask/processor/monitor_sys_resource" ) @@ -18,4 +19,5 @@ func InitCronQueue() { cron.CreateQueue("deleteExpiredRecord", deleteExpiredRecord.NewProcessor) cron.CreateQueue("backupEtcFromNE", backupEtcFromNE.NewProcessor) cron.CreateQueue("getStateFromNE", getStateFromNE.NewProcessor) + cron.CreateQueue("genNeStateAlarm", genNeStateAlarm.NewProcessor) }