Module: Superbolt

Defined in:
lib/superbolt/message_handler.rb,
lib/superbolt/app.rb,
lib/superbolt/queue.rb,
lib/superbolt/config.rb,
lib/superbolt/facade.rb,
lib/superbolt/router.rb,
lib/superbolt/version.rb,
lib/superbolt/messenger.rb,
lib/superbolt/processor.rb,
lib/superbolt/runner/pg.rb,
lib/superbolt/runner/ack.rb,
lib/superbolt/runner/pop.rb,
lib/superbolt/runner/base.rb,
lib/superbolt/adapter/amqp.rb,
lib/superbolt/adapter/base.rb,
lib/superbolt/spec_helpers.rb,
lib/superbolt/adapter/bunny.rb,
lib/superbolt/runner/greedy.rb,
lib/superbolt/connection/app.rb,
lib/superbolt/runner/ack_one.rb,
lib/superbolt/runner/default.rb,
lib/superbolt/connection/base.rb,
lib/superbolt/connection/queue.rb,
lib/superbolt/incoming_message.rb,
lib/superbolt/error_notifier/none.rb,
lib/superbolt/error_notifier/airbrake.rb

Overview

Subclass me to get an easy MessageHandler to plug into your router, no boilerplate. Just focus on the perform method that you need to build.

Defined Under Namespace

Modules: Adapter, Connection, ErrorNotifier, Runner, SpecHelpers Classes: App, Config, IncomingMessage, MessageHandler, Messenger, Processor, Queue, Router

Constant Summary collapse

VERSION = 
"0.7.5"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.app_name ⇒ Object

Returns the value of attribute app_name.



22
23
24
 
# File 'lib/superbolt/facade.rb', line 22

def app_name
  @app_name
end

.env ⇒ Object 



25
26
27
 
# File 'lib/superbolt/facade.rb', line 25

def self.env
  @env || 'development'
end

.error_notifier ⇒ Object 



33
34
35
 
# File 'lib/superbolt/facade.rb', line 33

def self.error_notifier
  @error_notifier || :none
end

.file_matcher ⇒ Object 



29
30
31
 
# File 'lib/superbolt/facade.rb', line 29

def self.file_matcher
  @file_matcher || /_file$/
end

Class Method Details

.config ⇒ Object 



12
13
14
 
# File 'lib/superbolt/facade.rb', line 12

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

.config=(options) ⇒ Object 



3
4
5
6
7
8
9
10
 
# File 'lib/superbolt/facade.rb', line 3

def self.config=(options)
  @config = Config.new({
    env: env,
    app_name: app_name,
    error_notifier: error_notifier,
    file_matcher: file_matcher
  }.merge(options))
end

.message(args = {}) ⇒ Object 



37
38
39
 
# File 'lib/superbolt/facade.rb', line 37

def self.message(args={})
  Superbolt::Messenger.new(args)
end

.queue(name) ⇒ Object 



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

def self.queue(name)
  Superbolt::Queue.new(name, config)
end