struct AvalancheMQ::ConsumerStore::ConsumerGroup

Defined in:

avalanchemq/consumer_store.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(priority : Int32, consumers : Deque(Client::Channel::Consumer)) #

[View source]

Instance Method Detail

def clone #

[View source]
def consumers : Deque(Client::Channel::Consumer) #

def copy_with(priority _priority = @priority, consumers _consumers = @consumers) #

[View source]
def priority : Int32 #