Module: Message::Q

Defined in:

lib/message/q.rb

Class Method Summary

• .adapter ⇒ Object
• .adapter=(name) ⇒ Object
• .adapters ⇒ Object
• .init(name) ⇒ Object
• .reset ⇒ Object

Class Method Details

.adapter ⇒ Object

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

def adapter
  @adapter ||= :in_memory
end

.adapter=(name) ⇒ Object

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

def adapter=(name)
  @adapter = name
end

.adapters ⇒ Object

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

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

.init(name) ⇒ Object

# File 'lib/message/q.rb', line 5

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

.reset ⇒ Object

# File 'lib/message/q.rb', line 21

def reset
  @adapter = nil
  @adapters = nil
end