module LavinMQ::AMQP::StreamFilter

Direct including types

Defined in:

lavinmq/amqp/stream/filters/filter.cr

Class Method Summary

Instance Method Summary

Class Method Detail

def self.from_arguments(arguments : AMQ::Protocol::Table) : Array(StreamFilter) #

Parse all filters from consumer arguments


[View source]

Instance Method Detail

abstract def match?(headers : AMQP::Table) : Bool #

[View source]