From 70695591218c1ee42cad58e9517b57114d687ed9 Mon Sep 17 00:00:00 2001 From: duyu Date: Fri, 13 Sep 2024 18:06:37 +0800 Subject: [PATCH] test --- app/services/transfersys/transfersys_rdb.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/services/transfersys/transfersys_rdb.go b/app/services/transfersys/transfersys_rdb.go index d6716a3..14344e8 100644 --- a/app/services/transfersys/transfersys_rdb.go +++ b/app/services/transfersys/transfersys_rdb.go @@ -62,7 +62,7 @@ func WriteOrder() { return } // 创建价格分组 - var queue_nos = [...]int{-1, 10, 20, 50, 100, 1000} + var queue_nos = [...]int{-1, 10, 20, 50, 100, 1000, 10210, 10220, 10250, 102100, 1021000} for _, value := range queue_nos { err = rdbmq.CreateStreamAndGroup(fmt.Sprintf("orders_%d", value), fmt.Sprintf("orders_%d", value)) if err != nil && err.Error() != "BUSYGROUP Consumer Group name already exists" {