class LavinMQ::AMQP::Consumer

Included Modules

Direct Known Subclasses

Defined in:

lavinmq/amqp/consumer.cr

Constant Summary

Log = LavinMQ::Log.for("amqp.consumer")

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

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(channel : AMQP::Channel, queue : Queue, frame : AMQP::Frame::Basic::Consume) #

[View source]

Instance Method Detail

def accepts? : Bool #

[View source]
def ack(sp) #

[View source]
def cancel #

[View source]
def channel : LavinMQ::AMQP::Channel #

[View source]
def channel_name #

[View source]
def close #

[View source]
def closed? : Bool #

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

[View source]
def details_tuple #

[View source]
def exclusive? : Bool #

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

[View source]
def has_capacity : Channel(Bool) #

[View source]
def no_ack? : Bool #

[View source]
def prefetch_count : UInt16 #

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

[View source]
def priority : Int32 #

[View source]
def queue : LavinMQ::AMQP::Queue #

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

[View source]
def tag : String #

[View source]
def unacked : UInt32 #

[View source]
def unacked_messages #

[View source]