diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go index 7baeda5..7b7f6d5 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -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)