log
This commit is contained in:
parent
6a15c47799
commit
8e964dd8a8
|
|
@ -109,7 +109,7 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
|
|||
{
|
||||
// Topic中没有消息可消费。
|
||||
if strings.Contains(err.(errors.ErrCode).Error(), "MessageNotExist") {
|
||||
fmt.Println("\nNo new message, continue!")
|
||||
//fmt.Println("\nNo new message, continue!")
|
||||
} else {
|
||||
log.Errorf("\tTopic中没有消息可消费判定报错:%v\n", err)
|
||||
time.Sleep(time.Duration(3) * time.Second)
|
||||
|
|
|
|||
Loading…
Reference in New Issue