From 10932348ff840fd7ea8b962f301682e037940202 Mon Sep 17 00:00:00 2001
From: eric <1048315650@qq.com>
Date: Mon, 13 Apr 2026 19:09:08 +0800
Subject: [PATCH] =?UTF-8?q?feat(xmsgbug):=20timeout=20=E9=80=BB=E8=BE=91?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 xmsgbus/subscriber.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/xmsgbus/subscriber.go b/xmsgbus/subscriber.go
index e7c2ec1..0aa35fb 100644
--- a/xmsgbus/subscriber.go
+++ b/xmsgbus/subscriber.go
@@ -113,6 +113,10 @@ func (x *Subscriber[T]) Handle(ctx context.Context) (err error) {
 	blockTimeout := time.Second * time.Duration(30+rand.Intn(15))
 	bs, ack, err := x.msgBus.Pop(ctx, x.topic, x.channel, blockTimeout)
 	if err != nil {
+		// 超时没有数据则直接返回，等待下一次调用
+		if err.Error() == "redis: nil" {
+			return nil
+		}
 		return err
 	}
 	defer ack()