class LavinMQ::Client::Channel::StreamConsumer

Defined in:

lavinmq/client/channel/stream_consumer.cr

Constructors

Instance Method Summary

Instance methods inherited from class LavinMQ::Client::Channel::Consumer

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

Constructor methods inherited from class LavinMQ::Client::Channel::Consumer

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

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, to_json(json : JSON::Builder) to_json

Constructor Detail

def self.new(channel : Client::Channel, queue : StreamQueue, frame : AMQP::Frame::Basic::Consume) #

[View source]

Instance Method Detail

def offset : Int64 #

[View source]
def offset=(offset : Int64) #

[View source]
def pos : UInt32 #

[View source]
def pos=(pos : UInt32) #

[View source]
def reject(sp, requeue : Bool) #

[View source]
def requeued : Deque(LavinMQ::SegmentPosition) #

[View source]
def segment : UInt32 #

[View source]
def segment=(segment : UInt32) #

[View source]