class LavinMQ::MQTT::Consumer

Defined in:

lavinmq/mqtt/client.cr

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json

Constructor Detail

def self.new(client : Client, session : MQTT::Session) #

[View source]

Instance Method Detail

def accepts? : Bool #

[View source]
def ack(sp) #

[View source]
def cancel #

[View source]
def close #

[View source]
def closed? #

[View source]
def deliver(msg, sp, redelivered = false, recover = false) #

[View source]
def deliver(msg : MQTT::Publish) #

[View source]
def details_tuple #

[View source]
def exclusive? #

[View source]
def flow(active : Bool) #

[View source]
def has_capacity : BoolChannel #

[View source]
def no_ack? #

[View source]
def prefetch_count : UInt16 #

[View source]
def prefetch_count=(prefetch_count : UInt16) #

[View source]
def priority #

[View source]
def reject(sp, requeue = false) #

[View source]
def tag : String #

[View source]
def unacked : UInt32 #

[View source]