rabbitmqpools

type ConsumeReceive struct {
	TagName      string                                                           //标识处理方法
	ExchangeName string                                                           //交换机
	ExchangeType string                                                           //交换机类型
	Route        string                                                           //路由
	QueueName    string                                                           //队列名称
	EventSuccess func(data *amqp.Delivery, retryClient RetryClientInterface) bool //成功事件回调
	EventFail    func(int, error, []byte)                                         //失败回调

	IsTry     bool  //是否重试
	MaxReTry  int32 //最大重式次数
	IsAutoAck bool  //是否自动确认
}

type QueueConsumerMode string

type RabbitAttribute struct {
	//交换机名称
	ExchangeName string `json:"exchangeName"`
	// 交换机模式[fanout 发布订阅模式,direct 路由模式，topic 主题模式，x-delayed-message 延时队列模式
	WorkModel string `json:"workModel"`
	//路由键《路由键和队列名称配合使用》
	RoutingKey string `json:"routingKey"`
	//队列名称《队列名称和路由键配合使用》
	Queue string `json:"queue"`
	//队列订阅消费的模式
	Modes []QueueConsumerMode `json:"modes"`
}

type RabbitLoadBalance struct {
}

type RabbitMqData struct {
	ExchangeName string //交换机名称
	ExchangeType string //交换机类型 见RabbitmqPool.go 常量
	QueueName    string //队列名称
	Route        string //路由
	Data         string //发送数据
}

type RabbitMqError struct {
	Code    int
	Message string
	Detail  string
}

type RabbitPool struct {
	// contains filtered or unexported fields
}

type RetryClientInterface interface {
	Push(pushData []byte) *RabbitMqError
	Ack() error
}

type RetryTool struct {
	// contains filtered or unexported fields
}

type RetryToolInterface interface {
	// contains filtered or unexported methods
}