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