struct LavinMQ::Client::Channel::Unack

Defined in:

lavinmq/client/channel.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(tag : UInt64, queue : Queue, sp : SegmentPosition, consumer : Consumer | Nil, delivered_at : Time::Span) #

[View source]

Instance Method Detail

def clone #

[View source]
def consumer : Consumer | Nil #

def copy_with(tag _tag = @tag, queue _queue = @queue, sp _sp = @sp, consumer _consumer = @consumer, delivered_at _delivered_at = @delivered_at) #

[View source]
def delivered_at : Time::Span #

def queue : Queue #

def sp : SegmentPosition #

def tag : UInt64 #