From 58aca1ca9ac1f65a0400f2bfa18afd29c5a22fac Mon Sep 17 00:00:00 2001 From: duyu Date: Wed, 11 Sep 2024 12:01:27 +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 0d6acde..d6716a3 100644 --- a/app/services/transfersys/transfersys_rdb.go +++ b/app/services/transfersys/transfersys_rdb.go @@ -24,7 +24,7 @@ func ReadGroup(queue_no int64) (order *models.Orders, err error) { streamName := "orders" groupName := "orders_one" consumerName := "cosumer_one" - if queue_no > 0 { + if queue_no != 0 { streamName = fmt.Sprintf("orders_%d", queue_no) groupName = fmt.Sprintf("orders_%d", queue_no) consumerName = fmt.Sprintf("cosumer_%d", queue_no)