class LavinMQ::Deduplication::Deduper

Defined in:

lavinmq/deduplication.cr

Constant Summary

DEFAULT_HEADER_KEY = "x-deduplication-header"

Constructors

Instance Method Summary

Constructor Detail

def self.new(cache : Cache(AMQ::Protocol::Field), default_ttl : UInt32 | Nil = nil, header_key : String | Nil = nil) #

[View source]

Instance Method Detail

def add(msg : Message) #

[View source]
def duplicate?(msg : Message) : Bool #

[View source]