class

LavinMQ::AMQP::StreamConsumer

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

Constructors

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

Instance methods

ack(sp)
Source
close
Source
filter_match?(msg_headers) : Bool
Source
notify_new_message
Source
offset
Source
offset=(offset : Int64)
Source
pos=(pos : UInt32)
Source
reject(sp, requeue : Bool)
Source
requeued
Source
segment
Source
segment=(segment : UInt32)
Source
segment_acquired=(segment_acquired : Bool)
Source
segment_acquired?
Source
segment_since
Source
segment_since=(segment_since : Time::Instant)
Source
waiting_for_messages?
Source