fix: fix the error

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)
 }

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: