Module: Qwrapper

Extended by:
Loggable
Defined in:
lib/qwrapper.rb,
lib/qwrapper/version.rb,
lib/qwrapper/queues/base.rb,
lib/qwrapper/support/config.rb,
lib/qwrapper/queues/rabbitmq.rb,
lib/qwrapper/support/loggable.rb

Overview

Qwrapper is an idomatic API for working with message queues.

Defined Under Namespace

Modules: Loggable, Queues Classes: Config, RequeueError

Constant Summary collapse

VERSION = 
"0.0.1"

Class Attribute Summary collapse

Class Method Summary collapse

Methods included from Loggable

logger, logger=

Class Attribute Details

.config ⇒ Object

Returns the value of attribute config.



13
14
15
 
# File 'lib/qwrapper.rb', line 13

def config
  @config
end

.version ⇒ String (readonly)

Returns Qwrapper version.

Returns:

  • (String) —

    Qwrapper version



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

def version
  @version
end

Class Method Details

.queue ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/qwrapper.rb', line 28

def queue
  @queue ||= begin
    base = Qwrapper::Queues::Base
    q = case self.config[:queue_type].to_s.to_sym
      when :rabbitmq
        then Qwrapper::Queues::RabbitMQ.new(self.config)
      when :"" then nil
      when nil then nil
      else raise "Unsupported queue_type '#{queue_type}'"
    end
  end
end