class LavinMQ::AMQP::Consumer

• LavinMQ::AMQP::Consumer
• LavinMQ::Client::Channel::Consumer
• Reference
• Object

Included Modules

• LavinMQ::SortableJSON

Direct Known Subclasses

• LavinMQ::AMQP::StreamConsumer

Defined in:

lavinmq/amqp/consumer.cr

Constant Summary

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

Constructors

• .new(channel : AMQP::Channel, queue : Queue, frame : AMQP::Frame::Basic::Consume)

Instance Method Summary

• #accepts? : Bool
• #ack(sp)
• #cancel
• #channel : LavinMQ::AMQP::Channel
• #channel_name
• #close
• #closed? : Bool
• #deliver(msg, sp, redelivered = false, recover = false)
• #details_tuple
• #exclusive? : Bool
• #flow(active : Bool)
• #has_capacity : Channel(Bool)
• #no_ack? : Bool
• #prefetch_count : UInt16
• #prefetch_count=(prefetch_count : UInt16)
• #priority : Int32
• #queue : LavinMQ::AMQP::Queue
• #reject(sp, requeue = false)
• #tag : String
• #unacked : UInt32
• #unacked_messages

Constructor Detail

Instance Method Detail