cmb
This commit is contained in:
parent
9e895e7114
commit
c20daf71fa
1
go.sum
1
go.sum
|
|
@ -126,6 +126,7 @@ github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeN
|
||||||
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
|
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
|
||||||
github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
|
github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
|
||||||
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
|
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
|
||||||
|
github.com/google/subcommands v1.2.0 h1:vWQspBTo2nEqTUFita5/KeEWlUL8kQObDFbub/EN9oE=
|
||||||
github.com/google/subcommands v1.2.0/go.mod h1:ZjhPrFU+Olkh9WazFPsl27BQ4UPiG37m3yTrtFlrHVk=
|
github.com/google/subcommands v1.2.0/go.mod h1:ZjhPrFU+Olkh9WazFPsl27BQ4UPiG37m3yTrtFlrHVk=
|
||||||
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||||
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
|
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
|
||||||
|
|
|
||||||
|
|
@ -94,11 +94,9 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
|
||||||
if errAckItems, ok := ackerr.(errors.ErrCode).Context()["Detail"].([]mqhttpsdk.ErrAckItem); ok {
|
if errAckItems, ok := ackerr.(errors.ErrCode).Context()["Detail"].([]mqhttpsdk.ErrAckItem); ok {
|
||||||
for _, errAckItem := range errAckItems {
|
for _, errAckItem := range errAckItems {
|
||||||
log.Errorf("\tErrorHandle:%s, ErrorCode:%s, ErrorMsg:%s\n", errAckItem.ErrorHandle, errAckItem.ErrorCode, errAckItem.ErrorMsg)
|
log.Errorf("\tErrorHandle:%s, ErrorCode:%s, ErrorMsg:%s\n", errAckItem.ErrorHandle, errAckItem.ErrorCode, errAckItem.ErrorMsg)
|
||||||
fmt.Printf("\tErrorHandle:%s, ErrorCode:%s, ErrorMsg:%s\n", errAckItem.ErrorHandle, errAckItem.ErrorCode, errAckItem.ErrorMsg)
|
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
log.Errorf("ackerr:%+v\n", ackerr)
|
log.Errorf("ack err:%+v\n", ackerr)
|
||||||
fmt.Println("ack err =", ackerr)
|
|
||||||
}
|
}
|
||||||
time.Sleep(time.Duration(3) * time.Second)
|
time.Sleep(time.Duration(3) * time.Second)
|
||||||
} else {
|
} else {
|
||||||
|
|
@ -113,7 +111,7 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
|
||||||
if strings.Contains(err.(errors.ErrCode).Error(), "MessageNotExist") {
|
if strings.Contains(err.(errors.ErrCode).Error(), "MessageNotExist") {
|
||||||
fmt.Println("\nNo new message, continue!")
|
fmt.Println("\nNo new message, continue!")
|
||||||
} else {
|
} else {
|
||||||
fmt.Println(err)
|
log.Errorf("\tTopic中没有消息可消费判定报错:%v\n", err)
|
||||||
time.Sleep(time.Duration(3) * time.Second)
|
time.Sleep(time.Duration(3) * time.Second)
|
||||||
}
|
}
|
||||||
endChan <- 1
|
endChan <- 1
|
||||||
|
|
@ -129,8 +127,8 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
|
||||||
// 长轮询消费消息,网络超时时间默认为35s。
|
// 长轮询消费消息,网络超时时间默认为35s。
|
||||||
// 长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。
|
// 长轮询表示如果Topic没有消息,则客户端请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回响应。
|
||||||
mqConsumer.ConsumeMessage(respChan, errChan,
|
mqConsumer.ConsumeMessage(respChan, errChan,
|
||||||
3, // 一次最多消费3条(最多可设置为16条)。
|
3, // 一次最多消费3条(最多可设置为16条)。
|
||||||
10, // 长轮询时间3s(最多可设置为30s)。
|
5, // 长轮询时间3s(最多可设置为30s)。
|
||||||
)
|
)
|
||||||
<-endChan
|
<-endChan
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue