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