queue_reliable

type RedisQueueStatus struct {
	Key         string // 标识消费者的唯一Key
	MachineName string // 机器名
	UserName    string // 用户名
	ProcessId   int    // 进程Id
	Ip          string // Ip地址
	CreateTime  int64  // 开始时间
	LastActive  int64  // 最后活跃时间
	Consumes    int64  // 消费消息数
	Acks        int64  // 确认消息数
}

type RedisReliableQueue struct {
	DB                          int
	ThrowOnFailure              bool   // 失败时抛出异常。默认false
	RetryTimesWhenSendFailed    int    //发送消息失败时的重试次数。默认3次
	RetryIntervalWhenSendFailed int    // 重试间隔。默认1000ms
	AckKey                      string // 用于确认的列表
	RetryInterval               int64  // 重新处理确认队列中死信的间隔。默认60s
	MinPipeline                 int64  // 最小管道阈值，达到该值时使用管道，默认3

	IsEmpty bool             // 是否为空
	Status  RedisQueueStatus // 消费状态
	// contains filtered or unexported fields
}