struct AvalancheMQ::Client::Channel::Unack

Defined in:

avalanchemq/client/channel.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(tag : UInt64, queue : Queue, sp : SegmentPosition, persistent : Bool, consumer : Consumer | Nil) #

[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, persistent _persistent = @persistent, consumer _consumer = @consumer) #

[View source]
def persistent : Bool #

def queue : Queue #

def sp : SegmentPosition #

def tag : UInt64 #