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" {