Module: Queuel

Extended by:
Forwardable, Introspect
Defined in:
lib/queuel.rb,
lib/queuel/client.rb,
lib/queuel/version.rb,
lib/queuel/sns/queue.rb,
lib/queuel/sqs/queue.rb,
lib/queuel/base/queue.rb,
lib/queuel/introspect.rb,
lib/queuel/null/queue.rb,
lib/queuel/sns/engine.rb,
lib/queuel/sqs/engine.rb,
lib/queuel/sqs/poller.rb,
lib/queuel/base/engine.rb,
lib/queuel/base/poller.rb,
lib/queuel/null/engine.rb,
lib/queuel/null/poller.rb,
lib/queuel/sqs/message.rb,
lib/queuel/base/message.rb,
lib/queuel/configurator.rb,
lib/queuel/null/message.rb,
lib/queuel/core_ext/hash.rb,
lib/queuel/iron_mq/queue.rb,
lib/queuel/iron_mq/engine.rb,
lib/queuel/iron_mq/poller.rb,
lib/queuel/iron_mq/message.rb,
lib/queuel/serialization/json.rb

Defined Under Namespace

Modules: Base, Introspect, IronMq, Null, SNS, SQS, Serialization Classes: Client, Configurator, Hash

Constant Summary collapse

NoQueueGivenError = 
Class.new StandardError
VERSION = 
"0.4.4"

Class Method Summary collapse

Methods included from Introspect

const_with_nesting, module_names

Class Method Details

.client ⇒ Object 



64
65
66
 
# File 'lib/queuel.rb', line 64

def self.client
  Client.new engine, credentials
end

.config ⇒ Object 



60
61
62
 
# File 'lib/queuel.rb', line 60

def self.config
  @config ||= Configurator.new
end

.configure(&block) ⇒ Object 



56
57
58
 
# File 'lib/queuel.rb', line 56

def self.configure(&block)
  config.instance_eval &block
end

.engine ⇒ Object 



50
51
52
53
54
 
# File 'lib/queuel.rb', line 50

def self.engine
  requires
  warn_engine_selection
  const_with_nesting engine_const_name
end

.logger ⇒ Object 



68
69
70
71
72
 
# File 'lib/queuel.rb', line 68

def self.logger
  config.logger.tap { |log|
    log.level = config.log_level
  }
end