class LavinMQ::Client::Channel::Consumer

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

Included Modules

• LavinMQ::SortableJSON

Direct Known Subclasses

• LavinMQ::Client::Channel::StreamConsumer

Defined in:

lavinmq/client/channel/consumer.cr

Constructors

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

Instance Method Summary

• #accepts? : Bool
• #ack(sp)
• #cancel
• #channel : LavinMQ::Client::Channel
• #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::Queue
• #reject(sp, requeue = false)
• #tag : String
• #unacked : UInt32

Constructor Detail

Instance Method Detail