contract

type Config interface {
	String() string
	PoolConfig() Pool
}

type Consumer interface {
	// QueueConsume 普通队列消费
	QueueConsume(consumer Handler) error
	// DelayQueueConsume 延时队列消费
	DelayQueueConsume(consumer Handler) error
	// Close 关闭连接
	Close() error
}

type Handler interface {
	// Handle 消费者处理器
	Handle(message message.Message) error
}

type Pool struct {
	MinConn     int
	MaxConn     int
	MaxIdleConn int
	IdleTimeout time.Duration
}

type Producer interface {
	// QueuePublish 发送普通队列消息
	QueuePublish(queueKey, messageBody string) (message.Message, error)
	// DelayQueuePublish 发送延时队列消息
	DelayQueuePublish(queueKey, messageBody string, ttl int64) (message.Message, error)
}