fusenapi/utils/mq_consumer_factory/mq.go

package mq_consumer_factory

import "context"

// 消费mq消息要实现对应Run方法
type MqHandle interface {
	Run(ctx context.Context, data []byte) error
}