rabbitMQ

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

type ConsumeReceive struct {
	ExchangeName string                                                                                  //交换机
	ExchangeType string                                                                                  //交换机类型
	Route        string                                                                                  //路由
	QueueName    string                                                                                  //队列名称
	EventSuccess func(data []byte, header map[string]interface{}, retryClient RetryClientInterface) bool //成功事件回调
	EventFail    func(int, error, []byte)                                                                //失败回调

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

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

type RabbitLoadBalance struct {
}

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

type RabbitMQError struct {
	Code    int
	Message string
	Detail  string
}

type RabbitMQPool 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
}