Skip to content

Commit 6980471

Browse files
liaobwRock-520
authored andcommitted
增强话题任务消息发布和订阅功能,添加AMQP消息属性以支持原始时间戳,优化队列参数设置,改进消息处理逻辑以确保消息顺序性和优先级管理。
1 parent f90c009 commit 6980471

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

backend/super-magic-module/src/Application/SuperAgent/Event/Subscribe/TopicTaskMessageSubscriber.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
exchange: 'super_magic_topic_task_message',
2727
routingKey: 'super_magic_topic_task_message',
2828
queue: 'super_magic_topic_task_message',
29-
nums: 1
29+
nums: 3
3030
)]
3131
class TopicTaskMessageSubscriber extends ConsumerMessage
3232
{

0 commit comments

Comments
 (0)