From dacaa47af35212809f3ba5a4806a4ff043c0470a Mon Sep 17 00:00:00 2001
From: luhaoling <2198702716@qq.com>
Date: Sun, 18 Feb 2024 19:12:46 +0800
Subject: [PATCH] fix: fix the error

---
 internal/msggateway/init.go  | 3 ---
 internal/msgtransfer/init.go | 1 +
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/internal/msggateway/init.go b/internal/msggateway/init.go
index f2bedbc9f..321407f7e 100644
--- a/internal/msggateway/init.go
+++ b/internal/msggateway/init.go
@@ -49,9 +49,6 @@ func RunWsAndServer(rpcPort, wsPort, prometheusPort int) error {
 		if err != nil {
 			netDone <- err
 		}
-		if err == nil {
-			fmt.Println("review SIGNAL but err is nil")
-		}
 	}()
 	return hubServer.LongConnServer.Run(netDone)
 }
diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go
index f14fe9109..2c70be1c3 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()
+		fmt.Println("SIGTERM SIGTERM received")
 		return errors.New("SIGTERM received, shutting down")
 
 	case <-netDone: