class Worker::CommandCallHandler::Queue

Defined in:

worker/command_call_handler/queue.cr

Constant Summary

DEFAULT_SIZE = 2
DM_TIMEOUT = 0.seconds
Log = CommandCallHandler::Log.for("queue")
SERVER_TIMEOUT = 1.second

Constructors

.new(worker : Worker, server_id : UInt64)

Instance Method Summary

#push(command_call : CommandCall)

Constructor Detail

def self.new(worker : Worker, server_id : UInt64) #

[View source]

Instance Method Detail

def push(command_call : CommandCall) #

[View source]