package mq_consumer_factory // 消费mq消息要实现对应Run方法 type MqHandle interface { Run(data []byte) error }