From 27529f4b9fc9d42079522f46575ed380dd4d2903 Mon Sep 17 00:00:00 2001 From: oribe Date: Wed, 27 Dec 2023 12:31:04 +0900 Subject: [PATCH] =?UTF-8?q?=E3=83=A1=E3=83=83=E3=82=BB=E3=83=BC=E3=82=B8?= =?UTF-8?q?=E3=81=AE=E5=8F=96=E5=BE=97=E3=81=A7=E3=82=A8=E3=83=A9=E3=83=BC?= =?UTF-8?q?=E3=81=8C=E7=99=BA=E7=94=9F=E3=81=97=E3=81=9F=E3=81=A8=E3=81=8D?= =?UTF-8?q?=E3=81=AF=E3=83=AB=E3=83=BC=E3=83=97=E3=82=92=E6=8A=9C=E3=81=91?= =?UTF-8?q?=E3=82=8B=E3=82=88=E3=81=86=E3=81=AB=E3=81=97=E3=81=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/traqmessage/collect.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/traqmessage/collect.go b/server/traqmessage/collect.go index b9f6e55..bac16e6 100644 --- a/server/traqmessage/collect.go +++ b/server/traqmessage/collect.go @@ -44,7 +44,7 @@ func (m *MessagePoller) Run() { messages, err := collectMessages(lastCheckpoint, now, i) if err != nil { slog.Error(fmt.Sprintf("Failled to polling messages: %v", err)) - continue + break } slog.Info(fmt.Sprintf("Collect %d messages", messages.TotalHits))