duyu
/
com.snow.auto_monitor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test

This commit is contained in:
duyu 2024-09-11 12:01:27 +08:00
parent 1e4ae43008
commit 58aca1ca9a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/services/transfersys/transfersys_rdb.go
View File

@ -24,7 +24,7 @@ func ReadGroup(queue_no int64) (order *models.Orders, err error) {
streamName := "orders" streamName := "orders"
groupName := "orders_one" groupName := "orders_one"
consumerName := "cosumer_one" consumerName := "cosumer_one"
if queue_no > 0 { if queue_no != 0 {
streamName = fmt.Sprintf("orders_%d", queue_no) streamName = fmt.Sprintf("orders_%d", queue_no)
groupName = fmt.Sprintf("orders_%d", queue_no) groupName = fmt.Sprintf("orders_%d", queue_no)
consumerName = fmt.Sprintf("cosumer_%d", queue_no) consumerName = fmt.Sprintf("cosumer_%d", queue_no)