From af85f4ea46ae6e33415bcd7c9458f376b008655e Mon Sep 17 00:00:00 2001
From: luhaoling <2198702716@qq.com>
Date: Sun, 18 Feb 2024 19:02:44 +0800
Subject: [PATCH] fix: fix the tranfer exit error

---
 internal/msgtransfer/init.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go
index 062017f44..f14fe9109 100644
--- a/internal/msgtransfer/init.go
+++ b/internal/msgtransfer/init.go
@@ -145,6 +145,7 @@ func (m *MsgTransfer) Start(prometheusPort int) error {
 		m.cancel()
 		m.historyCH.historyConsumerGroup.Close()
 		m.historyMongoCH.historyConsumerGroup.Close()
+		return errors.New("SIGTERM received, shutting down")
 
 	case <-netDone:
 		m.cancel()