fix: fix the tranfer exit error

2 years ago · af85f4ea46
parent 3d9700be29
commit af85f4ea46
1 changed files with 1 additions and 0 deletions
--- 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()