9 lines
162 B
Go
9 lines
162 B
Go
package mq_consumer_factory
|
|
|
|
import "context"
|
|
|
|
// 消费mq消息要实现对应Run方法
|
|
type MqHandle interface {
|
|
Run(ctx context.Context, data []byte) error
|
|
}
|