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