From 5eebddc6805b461c542594393b4188d44589cf5f Mon Sep 17 00:00:00 2001
From: ryan <kuyoeku@gmail.com>
Date: Tue, 18 Aug 2026 11:43:20 +0800
Subject: [PATCH] =?UTF-8?q?feat(=E6=B6=88=E6=81=AF=E8=AE=A2=E9=98=85):=20?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=B6=88=E6=81=AF=E6=8E=A5=E6=94=B6=E5=8E=9F?=
 =?UTF-8?q?=E5=A7=8B=E6=8A=A5=E6=96=87=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Motivation:
消息在分发处理前缺少接收环节的观测信息，排查消息丢失、重复消费或报文异常等问题时难以还原现场，需要在消息入口处记录完整的原始信息以支撑问题定位与链路追踪。

Changes:

* 在消息处理入口记录原始报文的接收日志
* 日志包含订阅者名称、队列、来源及投递标签等上下文信息
* 完整输出消息体内容，便于还原消息接收现场
---
 internal/subscriber/subscriber.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/internal/subscriber/subscriber.go b/internal/subscriber/subscriber.go
index f70dc88..7995aef 100644
--- a/internal/subscriber/subscriber.go
+++ b/internal/subscriber/subscriber.go
@@ -129,6 +129,14 @@ func (s *Subscriber) ensureQueue(ch *amqp.Channel) error {
 }
 
 func (s *Subscriber) handleDelivery(ch *amqp.Channel, d amqp.Delivery) {
+	slog.Info("raw message received",
+		"name", s.cfg.Name,
+		"queue", s.cfg.Queue,
+		"source", s.cfg.Source,
+		"delivery_tag", d.DeliveryTag,
+		"body", string(d.Body),
+	)
+
 	disp := HandleMessage(context.Background(), HandleInput{
 		Body:       d.Body,
 		Headers:    map[string]any(d.Headers),