class AvalancheMQ::Client::Channel::Consumer

Included Modules

Defined in:

avalanchemq/client/channel/consumer.cr

Constructors

Instance Method Summary

Instance methods inherited from module AvalancheMQ::SortableJSON

details_tuple details_tuple, to_json(json : JSON::Builder) to_json

Constructor Detail

def self.new(channel : Client::Channel, tag : String, queue : Queue, no_ack : Bool, exclusive : Bool, priority : Int32) #

[View source]

Instance Method Detail

def accepts? #

[View source]
def ack(sp) #

[View source]
def cancel #

[View source]
def channel : AvalancheMQ::Client::Channel #

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

[View source]
def details_tuple #

[View source]
def exclusive : Bool #

[View source]
def name : String #

[View source]
def no_ack : Bool #

[View source]
def prefetch_count #

[View source]
def priority : Int32 #

[View source]
def queue : AvalancheMQ::Queue #

[View source]
def recover(requeue) #

[View source]
def reject(sp) #

[View source]
def tag : String #

[View source]
def unacked : UInt32 #

[View source]