|
|
@@ -87,10 +87,10 @@ func SendMQ(c *gin.Context, req *request.MQBodyReq) (err error) {
|
|
|
select {
|
|
|
case r := <-asyncTask.Rsp: // 总线回复
|
|
|
rsp.OkWithData(r, c)
|
|
|
- case <-time.After(time.Second * 30): // 超时
|
|
|
+ case <-time.After(time.Second * 20): // 超时
|
|
|
// 删除对应异步任务
|
|
|
t.DeleteAsyncTask(key)
|
|
|
- rsp.FailWithMessage("业务超时", c)
|
|
|
+ rsp.FailWithCodeAndDetail(nil, 11, "业务超时", c)
|
|
|
}
|
|
|
asyncTask.Finish()
|
|
|
|