Release v0.2.22

factory/rabbitmq/consumer_factory.go

@@ -3,14 +3,15 @@ package rabbitmq
 import (
 	"fmt"
 
-	"git.x2erp.com/qdy/go-base/model/request"
+	"git.x2erp.com/qdy/go-base/model/request/mqreq"
+	mq "git.x2erp.com/qdy/go-base/model/request/mqreq"
 	"git.x2erp.com/qdy/go-base/model/response"
 	amqp "github.com/streadway/amqp"
 )
 
 // MessageHandler 消息处理器接口
 type MessageHandler interface {
-	Process(ueueRequest *request.QueueRequest, body []byte) response.QueryResult[interface{}]
+	Process(ueueRequest *mq.QueueRequest, body []byte) response.QueryResult[interface{}]
 }
 
 // Consumer 消费者结构体
@@ -18,12 +19,12 @@ type Consumer struct {
 	Channel      *amqp.Channel
 	QueueName    string
 	Handler      MessageHandler
-	QueueRequest *request.QueueRequest
+	QueueRequest *mq.QueueRequest
 }
 
 // CreateConsumer 创建消费者
 // 返回Consumer对象，创建后自动开始消费
-func (f *RabbitMQFactory) CreateConsumer(queueRequest *request.QueueRequest, consumerID string, handler MessageHandler) (*Consumer, error) {
+func (f *RabbitMQFactory) CreateConsumer(queueRequest *mqreq.QueueRequest, consumerID string, handler MessageHandler) (*Consumer, error) {
 	// 生成唯一的通道名称
 	channelName := fmt.Sprintf("%s_%s", queueRequest.QueueName, consumerID)