Browse Source

增加自动获取所有配置文件方法,增加微服务配置插入删除方法

qdy 1 month ago
parent
commit
fca162ff43
1 changed files with 5 additions and 4 deletions
  1. 5
    4
      factory/rabbitmq/consumer_factory.go

+ 5
- 4
factory/rabbitmq/consumer_factory.go View File

3
 import (
3
 import (
4
 	"fmt"
4
 	"fmt"
5
 
5
 
6
-	"git.x2erp.com/qdy/go-base/model/request"
6
+	"git.x2erp.com/qdy/go-base/model/request/mqreq"
7
+	mq "git.x2erp.com/qdy/go-base/model/request/mqreq"
7
 	"git.x2erp.com/qdy/go-base/model/response"
8
 	"git.x2erp.com/qdy/go-base/model/response"
8
 	amqp "github.com/streadway/amqp"
9
 	amqp "github.com/streadway/amqp"
9
 )
10
 )
10
 
11
 
11
 // MessageHandler 消息处理器接口
12
 // MessageHandler 消息处理器接口
12
 type MessageHandler interface {
13
 type MessageHandler interface {
13
-	Process(ueueRequest *request.QueueRequest, body []byte) response.QueryResult[interface{}]
14
+	Process(ueueRequest *mq.QueueRequest, body []byte) response.QueryResult[interface{}]
14
 }
15
 }
15
 
16
 
16
 // Consumer 消费者结构体
17
 // Consumer 消费者结构体
18
 	Channel      *amqp.Channel
19
 	Channel      *amqp.Channel
19
 	QueueName    string
20
 	QueueName    string
20
 	Handler      MessageHandler
21
 	Handler      MessageHandler
21
-	QueueRequest *request.QueueRequest
22
+	QueueRequest *mq.QueueRequest
22
 }
23
 }
23
 
24
 
24
 // CreateConsumer 创建消费者
25
 // CreateConsumer 创建消费者
25
 // 返回Consumer对象,创建后自动开始消费
26
 // 返回Consumer对象,创建后自动开始消费
26
-func (f *RabbitMQFactory) CreateConsumer(queueRequest *request.QueueRequest, consumerID string, handler MessageHandler) (*Consumer, error) {
27
+func (f *RabbitMQFactory) CreateConsumer(queueRequest *mqreq.QueueRequest, consumerID string, handler MessageHandler) (*Consumer, error) {
27
 	// 生成唯一的通道名称
28
 	// 生成唯一的通道名称
28
 	channelName := fmt.Sprintf("%s_%s", queueRequest.QueueName, consumerID)
29
 	channelName := fmt.Sprintf("%s_%s", queueRequest.QueueName, consumerID)
29
 
30
 

Loading…
Cancel
Save