chore(queue): add size param for redis queue engine (#796)

appleboy · Jul 17, 2024 · 0199ac4 · 0199ac4
1 parent 4831a23
commit 0199ac4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/main.go b/main.go
@@ -333,6 +333,7 @@ func main() {
 			redisdb.WithStreamName(cfg.Queue.Redis.StreamName),
 			redisdb.WithGroup(cfg.Queue.Redis.Group),
 			redisdb.WithConsumer(cfg.Queue.Redis.Consumer),
+			redisdb.WithMaxLength(cfg.Core.QueueNum),
 			redisdb.WithRunFunc(notify.Run(cfg)),
 			redisdb.WithLogger(logx.QueueLogger()),
 		)