class AvalancheMQ::ConsumerStore

Defined in:

avalanchemq/consumer_store.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new #

[View source]

Instance Method Detail

def add_consumer(consumer) #

[View source]
def cancel_consumers #

[View source]
def capacity #

[View source]
def clear #

[View source]
def delete_consumer(consumer) #

[View source]
def each(&) #

[View source]
def empty? #

[View source]
def first #

[View source]
def first? #

[View source]
def immediate_delivery? #

[View source]
def next_consumer(i) #

[View source]
def size : UInt32 #

[View source]
def to_json(builder : JSON::Builder) #

[View source]