class LavinMQ::AMQP::StreamConsumer

Included Modules

Defined in:

lavinmq/amqp/stream_consumer.cr

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json

Instance methods inherited from class LavinMQ::AMQP::Consumer

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

Constructor methods inherited from class LavinMQ::AMQP::Consumer

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

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, 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 ack(sp) #

[View source]
def filter_match?(msg_headers) : Bool #

[View source]
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]