class Asynchronic::QueueEngine::InMemory
Attributes
options[R]
queues[R]
Public Class Methods
new(options={})
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 5 def initialize(options={}) @options = options @queues ||= Hash.new { |h,k| h[k] = Queue.new } end
Public Instance Methods
[](name)
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 14 def [](name) queues[name] end
active_connections()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 34 def active_connections [Asynchronic.connection_name] end
asynchronic?()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 30 def asynchronic? true end
clear()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 22 def clear queues.clear end
default_queue()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 10 def default_queue @default_queue ||= options.fetch(:default_queue, Asynchronic.default_queue) end
listener()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 26 def listener Listener.new end
queue_names()
click to toggle source
# File lib/asynchronic/queue_engine/in_memory.rb, line 18 def queue_names queues.keys.map(&:to_sym) end