Merge pull request 'hotfix' (#33 ) from hotfix into main

Reviewed-on: #33
Merge remote-tracking branch 'origin/hotfix' into hotfix
2024-03-22 23:07:45 +08:00 · 2024-03-22 23:07:00 +08:00 · 2024-03-22 23:06:54 +08:00
3 changed files with 7 additions and 0 deletions
--- a/config.yaml
+++ b/config.yaml
@ -37,6 +37,8 @@ task:

 # MQ配置
 mq:
+  # 是否启用
+  enable: false
  # RabbitMQ配置
  rabbitmq:
    host: 10.0.0.247
--- a/config/mq.go
+++ b/config/mq.go
@ -5,6 +5,7 @@ import "fmt"
 // mq
 // @description: MQ配置
 type mq struct {
+	Enable   bool     `json:"enable" yaml:"enable"`     // 是否启用
 	RabbitMQ rabbitMq `json:"rabbitmq" yaml:"rabbitmq"` // RabbitMQ配置
 }

--- a/mq/rabbitmq.go
+++ b/mq/rabbitmq.go
@ -16,6 +16,10 @@ const exchangeName = "wechat-message"
 // Init
 // @description: 初始化MQ
 func Init() {
+	if !config.Conf.Mq.Enable {
+		log.Println("未启用MQ")
+		return
+	}
 	// 读取MQ连接配置
 	mqUrl := config.Conf.Mq.RabbitMQ.GetURL()
 	if mqUrl == "" {
Author	SHA1	Message	Date
李寻欢	22c7d3683b	Merge pull request 'hotfix' (#33 ) from hotfix into main BuildImage / build-image (push) Successful in 1m34s Details Reviewed-on: #33	2024-03-22 23:07:45 +08:00
李寻欢	d589a9615e	Merge remote-tracking branch 'origin/hotfix' into hotfix	2024-03-22 23:07:00 +08:00
李寻欢	13205e445f	🎨 新增 MQ 开关	2024-03-22 23:06:54 +08:00