Module: Rabbitek

Defined in:
lib/rabbitek.rb,
lib/rabbitek/cli.rb,
lib/rabbitek/rails.rb,
lib/rabbitek/config.rb,
lib/rabbitek/version.rb,
lib/rabbitek/loggable.rb,
lib/rabbitek/utils/oj.rb,
lib/rabbitek/utils/common.rb,
lib/rabbitek/server/batcher.rb,
lib/rabbitek/server/message.rb,
lib/rabbitek/server/retryer.rb,
lib/rabbitek/server/starter.rb,
lib/rabbitek/server/consumer.rb,
lib/rabbitek/bunny_connection.rb,
lib/rabbitek/client/publisher.rb,
lib/rabbitek/utils/hook_walker.rb,
lib/rabbitek/client/client_hook.rb,
lib/rabbitek/server/hooks/retry.rb,
lib/rabbitek/server/server_hook.rb,
lib/rabbitek/utils/open_tracing.rb,
lib/rabbitek/cli/signal_handlers.rb,
lib/rabbitek/client/hooks/opentracing.rb,
lib/rabbitek/server/hooks/opentracing.rb,
lib/rabbitek/server/message_processor.rb,
lib/rabbitek/server/hooks/time_tracker.rb,
lib/rabbitek/utils/rabbit_object_names.rb,
lib/rabbitek/server/hooks/active_record_connection_reset.rb

Overview

High performance background job processing using RabbitMQ

Defined Under Namespace

Modules: Client, Consumer, Loggable, Server, Utils Classes: Batcher, BunnyConnection, CLI, ClientHook, Config, Message, MessageProcessor, Publisher, Rails, Retryer, ServerHook, Starter

Constant Summary collapse

VERSION = 
'0.8.1'

Class Method Summary collapse

Class Method Details

.bunny_connection ⇒ Object 



54
55
56
 
# File 'lib/rabbitek.rb', line 54

def self.bunny_connection
  @bunny_connection ||= BunnyConnection.initialize_connection
end

.close_bunny_connection ⇒ Object 



50
51
52
 
# File 'lib/rabbitek.rb', line 50

def self.close_bunny_connection
  bunny_connection.close
end

.config ⇒ Object 



30
31
32
 
# File 'lib/rabbitek.rb', line 30

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

.configure {|config| ... } ⇒ Object

Yields:



34
35
36
 
# File 'lib/rabbitek.rb', line 34

def self.configure
  yield(config)
end

.create_channel ⇒ Object 



46
47
48
 
# File 'lib/rabbitek.rb', line 46

def self.create_channel
  bunny_connection.create_channel
end

.logger ⇒ Object 



42
43
44
 
# File 'lib/rabbitek.rb', line 42

def self.logger
  @config.logger
end

.reloader ⇒ Object 



38
39
40
 
# File 'lib/rabbitek.rb', line 38

def self.reloader
  config.reloader
end