From 98330159fe76768e8556eb6d4ae82173675a8764 Mon Sep 17 00:00:00 2001 From: luhaoling <2198702716@qq.com> Date: Sun, 18 Feb 2024 19:33:00 +0800 Subject: [PATCH] fix: del the error return in tranfer --- internal/msgtransfer/init.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 2c70be1c3..062017f44 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -145,8 +145,6 @@ func (m *MsgTransfer) Start(prometheusPort int) error { m.cancel() m.historyCH.historyConsumerGroup.Close() m.historyMongoCH.historyConsumerGroup.Close() - fmt.Println("SIGTERM SIGTERM received") - return errors.New("SIGTERM received, shutting down") case <-netDone: m.cancel()