diff --git a/internal/nodes/http_access_log_queue.go b/internal/nodes/http_access_log_queue.go index cfae612..1dd7439 100644 --- a/internal/nodes/http_access_log_queue.go +++ b/internal/nodes/http_access_log_queue.go @@ -43,7 +43,11 @@ func (this *HTTPAccessLogQueue) Start() { for range ticker.C { err := this.loop() if err != nil { - remotelogs.Error("ACCESS_LOG_QUEUE", err.Error()) + if rpc.IsConnError(err) { + remotelogs.Debug("ACCESS_LOG_QUEUE", err.Error()) + } else { + remotelogs.Error("ACCESS_LOG_QUEUE", err.Error()) + } } } }