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