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 }