hooks

type FilterMessageContext struct {
	ConsumerGroup string
	Msg           []*primitive.MessageExt
	MQ            *primitive.MessageQueue
	Arg           interface{}
	UnitMode      bool
}

type FilterMessageHook func(ctx *FilterMessageContext) ([]*primitive.MessageExt, error)