From 155a54f536effd604779f37114d376162dd67b7b Mon Sep 17 00:00:00 2001 From: ryan Date: Mon, 17 Aug 2026 17:01:37 +0800 Subject: [PATCH] =?UTF-8?q?fix(crypto=E7=AD=96=E7=95=A5):=20=E8=AE=A2?= =?UTF-8?q?=E9=98=85=E8=B7=AF=E7=94=B1=E9=94=AE=E6=94=B9=E4=B8=BA=E9=80=9A?= =?UTF-8?q?=E9=85=8D=E7=AC=A6=E4=BB=A5=E8=A6=86=E7=9B=96=E6=9D=A5=E6=BA=90?= =?UTF-8?q?=E7=BB=B4=E5=BA=A6=E7=9A=84=E4=BF=A1=E5=8F=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Motivation: 去重键已加入来源维度,信号会以 strategy.signal.origin 路由键发布,原精确匹配策略将漏收该类消息,需扩展订阅范围。 Changes: * 将 routing_key 由 strategy.signal 改为 strategy.signal.# 通配符 * 新增注释说明通配符覆盖 strategy.signal 与 strategy.signal.origin --- config/config.yaml | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/config/config.yaml b/config/config.yaml index b911936..8c8a565 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -59,11 +59,12 @@ subscriptions: - name: crypto-strategy url: "${RABBITMQ_URL}" # 独立队列,不订 executor 队列,避免和 consumer.strategy 抢消息 + # strategy.signal.# 覆盖 strategy.signal 与 strategy.signal.origin queue: crypto.strategy.signal.notify.queue dead_letter_queue: crypto.strategy.signal.notify.dlq exchange: crypto.strategy.topic exchange_type: topic - routing_key: strategy.signal + routing_key: strategy.signal.# max_retry: 3 source: crypto-strategy formatter: crypto_strategy