struct AvalancheMQ::Queue::UnackQueue::Unack

Defined in:

avalanchemq/queue/unacked.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(sp : SegmentPosition, persistent : Bool, consumer : Client::Channel::Consumer | Nil) #

[View source]

Instance Method Detail

def clone #

[View source]
def consumer : Client::Channel::Consumer | Nil #

def copy_with(sp _sp = @sp, persistent _persistent = @persistent, consumer _consumer = @consumer) #

[View source]
def persistent : Bool #

def sp : SegmentPosition #