From 83b33573d5f474c4a1ce8342902a429bd1bed253 Mon Sep 17 00:00:00 2001
From: eric <1048315650@qq.com>
Date: Mon, 13 Apr 2026 18:34:32 +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 | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/xmsgbus/subscriber.go b/xmsgbus/subscriber.go
index 9571498..33f1d4c 100644
--- a/xmsgbus/subscriber.go
+++ b/xmsgbus/subscriber.go
@@ -110,10 +110,8 @@ func (x *Subscriber[T]) Handle(ctx context.Context) (err error) {
 		return err
 	}
 	// 一次 handle 监听不超过 [30,45) 秒
-	timeoutCtx, cancel := context.WithTimeout(ctx, time.Second*time.Duration(30+rand.Intn(15)))
-	defer cancel()
-
-	bs, ack, err := x.msgBus.Pop(timeoutCtx, x.topic, x.channel, 0)
+	blockTimeout := time.Second * time.Duration(30+rand.Intn(15))
+	bs, ack, err := x.msgBus.Pop(timeoutCtx, x.topic, x.channel, blockTimeout)
 	if err != nil {
 		return err
 	}