class Queuing::Queue

Defined in:

queuing/queue.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(name : String, storage : QueueStorage) #

[View source]

Instance Method Detail

def ch_input : Channel(Queuing::InputCommandInfo) #

[View source]
def ch_storage #

[View source]
def generate_queue_tick #

[View source]
def handle_msg(command : InputCommandInfo) #

[View source]
def len #

[View source]
def name : String #

[View source]
def process_input #

[View source]
def publish(command : InputCommandInfo) #

[View source]
def storage : Queuing::QueueStorage #

[View source]
def subscribe(command : InputCommandInfo) #

[View source]
def subscribers : Hash(TCPSocket?, Bool) #

[View source]
def unsubscribe(command : InputCommandInfo) #

[View source]