From 2c34d5630212e52956eb9287008cfa7f2b3f49b4 Mon Sep 17 00:00:00 2001 From: duyu Date: Mon, 23 Sep 2024 15:10:52 +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 25b702e..b29783a 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, 102, 10210, 10220, 10250, 102100, 1021000} + var queue_nos = [...]int{-5, -4, -3, -2, -1, 10, 20, 50, 100, 1000, 102, 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" {