Module: Message::Q

Defined in:
lib/message/q.rb

Class Method Summary collapse

Class Method Details

.adapter ⇒ Object 



16
17
18
 
# File 'lib/message/q.rb', line 16

def adapter
  @adapter ||= :in_memory
end

.adapter=(name) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/message/q.rb', line 20

def adapter=(name)
  if name.nil?
    @adapter = nil
    return
  end
  name = name.to_sym
  unless adapters.has_key?(name)
    raise AdapterNotFoundError, "Could not find adapter named #{name.inspect}"
  end
  @adapter = name
end

.adapters ⇒ Object 



12
13
14
 
# File 'lib/message/q.rb', line 12

def adapters
  @adapters ||= { :in_memory => InMemoryQueue }
end

.init(name) ⇒ Object 



8
9
10
 
# File 'lib/message/q.rb', line 8

def init(name)
  adapters[adapter].new(name)
end

.reset ⇒ Object 



32
33
34
35
 
# File 'lib/message/q.rb', line 32

def reset
  @adapter = nil
  @adapters = nil
end