From 183ce252b7fe1f96e4983492dffa9da9bb56227f Mon Sep 17 00:00:00 2001 From: qhd <1766646056@qq.com> Date: Wed, 31 Dec 2025 10:57:57 +0800 Subject: [PATCH] =?UTF-8?q?redis=E6=B6=88=E8=B4=B9=E9=98=9F=E5=88=97?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- redis/message.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/redis/message.go b/redis/message.go index a20f019..a9cfcbe 100644 --- a/redis/message.go +++ b/redis/message.go @@ -6,9 +6,8 @@ type QueueMessage struct { StreamKey string // Stream 键名 GroupName string // 消费者组名称 ConsumerName string // 消费者名称 - Timeout int64 // 阻塞超时时间(毫秒) BatchSize int64 // 最大并发数(信号量容量) BlockMs int64 // 阻塞时间 - AutoAck bool //ACK确认,true自动确认,false手动确认 + AutoAck bool // ACK确认,true自动确认,false手动确认 HandleFunc func(ctx context.Context, message map[string]interface{}) error }