|
@@ -221,7 +221,7 @@ class AgentService:
|
|
|
# 系统消息使用特定的msgId,无实际意义
|
|
|
msg.msgId = -MessageType.AGGREGATION_TRIGGER.value
|
|
|
if self.scheduler_mode == 'mq':
|
|
|
- self.scheduler_queue.produce(msg)
|
|
|
+ self.scheduler_queue.produce(msg, msg_group='agent_system')
|
|
|
else:
|
|
|
self.scheduler.add_job(lambda: self.receive_queue.produce(msg),
|
|
|
'date',
|