filter

Sep 14, 2023

Changes in this version

+ const DirectionKey

+ const MessageTypeKey

+ const ProtocolKey

+ const SessionAliasKey

+ func FirstIDFromMsgBatch(batch *p_buff.MessageGroupBatch) *p_buff.MessageID

+ func FirstIDFromMsgGroup(group *p_buff.MessageGroup) *p_buff.MessageID

+ func IDFromAnyMsg(msg *p_buff.AnyMessage) *p_buff.MessageID

+ type Strategy interface

+ Verify func(messages *p_buff.MessageGroupBatch, filters []mqFilter.FilterConfiguration) bool

+ var Default Strategy = defaultFilterStrategy{}