Exit the executor process when failed to connect to the rabbitmq mess…

…age queue.
sunmao-dx · Jun 29, 2023 · ee2effb · ee2effb
1 parent 0802992
commit ee2effb
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/server.go b/src/server.go
@@ -37,6 +37,7 @@ func doRabbitMQ() {
 		gitee_utils.LogInstance.WithFields(logrus.Fields{
 			"context": "Rabbitmq connect error",
 		}).Info("info log")
+		os.Exit(1)
 	}
 	cc := gitee_utils.ConsumerConfig{
 		ExchangeName:  RMQ_EXCHANGE_NAME,
@@ -53,6 +54,7 @@ func doRabbitMQ() {
 		gitee_utils.LogInstance.WithFields(logrus.Fields{
 			"context": "Consumer setup error",
 		}).Info("info log")
+		os.Exit(1)
 	}
 	gitee_utils.LogInstance.WithFields(logrus.Fields{
 		"context": "Consumer action success",