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)