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: