module Emque::Consuming::Adapters::RabbitMq

Public Class Methods

default_options() click to toggle source
# 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() click to toggle source
# 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() click to toggle source
# File lib/emque/consuming/adapters/rabbit_mq.rb, line 21
def self.manager
  Emque::Consuming::Adapters::RabbitMq::Manager
end