Versions in this module Expand all Collapse all v2 v2.1.4 Nov 7, 2023 Changes in this version + type FilterMessageContext struct + Arg interface{} + ConsumerGroup string + MQ *primitive.MessageQueue + Msg []*primitive.MessageExt + UnitMode bool + type FilterMessageHook func(ctx *FilterMessageContext) ([]*primitive.MessageExt, error)
Go to main page