From 836460306eeafc57efe6a637de0de613c51fa1db Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Mon, 29 Dec 2025 14:52:31 +0800
Subject: [PATCH] =?UTF-8?q?mongo=E6=95=B0=E6=8D=AE=E5=BA=93=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0=E6=98=AF=E5=90=A6=E9=87=8D=E7=BC=93=E5=AD=98=E6=9F=A5?=
 =?UTF-8?q?=E8=AF=A2=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=A2=9E=E5=8A=A0=E9=9A=8F?=
 =?UTF-8?q?=E6=9C=BA=E4=BF=AE=E6=94=B9=E5=88=A0=E9=99=A4=E7=8A=B6=E6=80=81?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=EF=BC=9Bredis=E5=A2=9E=E5=8A=A0-=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E6=B6=88=E6=81=AF=E8=AF=BB=E5=8F=96=E5=B0=81=E8=A3=85?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 redis/redis.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/redis/redis.go b/redis/redis.go
index aa4e947..c338e75 100644
--- a/redis/redis.go
+++ b/redis/redis.go
@@ -81,7 +81,7 @@ func GetReadStream(ctx context.Context, msg ...QueueMessage) error {
 	return nil
 }
 
-// GetReadFromStream 读取ReadFromStream数据
+// GetReadFromStream  读取ReadFromStream数据
 func GetReadFromStream(ctx context.Context, streamKey, groupName, consumerName string, count, blockMs int64, Block bool, fn func(ctx context.Context, message map[string]interface{}) error) (err error) {
 	glog.Infof(ctx, "初始化 Stream: %s, 消费者组: %s", streamKey, groupName)
 	err = InitStreamGroup(ctx, streamKey, groupName)