Module: Emque::Consuming::Adapters::RabbitMq

Defined in:
lib/emque/consuming/adapters/rabbit_mq.rb,
lib/emque/consuming/adapters/rabbit_mq/worker.rb,
lib/emque/consuming/adapters/rabbit_mq/manager.rb,
lib/emque/consuming/adapters/rabbit_mq/error_worker.rb,
lib/emque/consuming/adapters/rabbit_mq/delayed_message_worker.rb

Defined Under Namespace

Classes: DelayedMessageWorker, ErrorWorker, Manager, Worker

Class Method Summary collapse

Class Method Details

.default_options ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/emque/consuming/adapters/rabbit_mq.rb', line 5

def self.default_options
  {
    :url => "amqp://guest:guest@localhost:5672",
    :prefetch => nil,
    :durable => true,
    :auto_delete => false
  }
end

.load ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/emque/consuming/adapters/rabbit_mq.rb', line 14

def self.load
  require_relative "rabbit_mq/manager"
  require_relative "rabbit_mq/worker"
  require_relative "rabbit_mq/error_worker"
  require_relative "rabbit_mq/delayed_message_worker"
end

.manager ⇒ Object 



21
22
23
 
# File 'lib/emque/consuming/adapters/rabbit_mq.rb', line 21

def self.manager
  Emque::Consuming::Adapters::RabbitMq::Manager
end