jen/epusdt
1
0
Fork 0
mirror of https://github.com/GMWalletApp/epusdt.git synced 2026-07-07 10:16:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

debug

Browse Source
This commit is contained in:
noreply
2024-04-16 23:55:11 +08:00
parent d3ed2c927e
commit ed0a7f7d07
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/model/service/task_service.go
+2 -1
View File
@@ -5,6 +5,8 @@ import (
"net/http" "net/http"
"sync" "sync"
"github.com/spf13/viper"
"github.com/assimon/luuu/model/data" "github.com/assimon/luuu/model/data"
"github.com/assimon/luuu/model/request" "github.com/assimon/luuu/model/request"
"github.com/assimon/luuu/mq" "github.com/assimon/luuu/mq"
@@ -136,7 +138,6 @@ func Trc20CallBack(token string, wg *sync.WaitGroup) {
} }
// 回调队列 // 回调队列
orderCallbackQueue, _ := handle.NewOrderCallbackQueue(order) orderCallbackQueue, _ := handle.NewOrderCallbackQueue(order)
orderCallbackQueue, _ := handle.NewOrderCallbackQueue(order)
orderNoticeMaxRetry := viper.GetInt("order_notice_max_retry") orderNoticeMaxRetry := viper.GetInt("order_notice_max_retry")
mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(orderNoticeMaxRetry)) mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(orderNoticeMaxRetry))
// mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(5)) // mq.MClient.Enqueue(orderCallbackQueue, asynq.MaxRetry(5))