class

LavinMQ::AMQP::Consumer

Inherits LavinMQ::SortableJSON < LavinMQ::Client::Channel::Consumer < LavinMQ::SortableJSON < Reference < Object

Constants

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

Constructors

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

Instance methods

accepts?
Source
ack(sp)
Source
cancel
Source
channel
Source
close
Source
closed?
Source
deliver(msg, sp, redelivered = false, recover = false)
Source
details_tuple
Source
ensure_deliver_loop
Source
exclusive?
Source
flow(active : Bool)
Source
flush
Source
has_capacity
Source
no_ack?
Source
prefetch_count
Source
prefetch_count=(prefetch_count : UInt16)
Source
priority
Source
queue
Source
reject(sp, requeue = false)
Source
unacked
Source
unacked_messages
Source

Nested types