class

LavinMQ::Deduplication::Deduper

Inherits Reference < Object

Constants

DEFAULT_HEADER_KEY = "x-deduplication-header"

Constructors

new(cache : Cache(AMQ::Protocol::Field), default_ttl : UInt32 | Nil = nil, header_key : String | Nil = nil)
Source

Instance methods

add(msg : Message)
Source
duplicate?(msg : Message) : Bool
Source