listener

type ConsumeConcurrentlyStatus ¶

type ConsumeConcurrentlyStatus int

ConsumeConcurrentlyStatus: 普通消费状态回执 Author: yintongqiang Since: 2017/8/10

const (
	CONSUME_SUCCESS ConsumeConcurrentlyStatus = iota // Success consumption
	RECONSUME_LATER                                  // Failure consumption,later try to consume
)

func (cct ConsumeConcurrentlyStatus) String() string

type MessageListener ¶

type MessageListener interface {
}