Adds spec updates.

lib/emque/consuming/adapters/rabbit_mq/manager.rb

@@ -1,4 +1,6 @@
 require "bunny"
+require_relative "error_worker"
+require_relative "delayed_message_worker"
 
 module Emque
   module Consuming

spec/adapters/rabbit_mq/worker/worker_spec.rb

@@ -2,26 +2,95 @@
 require "emque/consuming/adapters/rabbit_mq/worker"
 require "pry"
 
+module Emque
+  module Consuming
+    module Adapters
+      module RabbitMq
+        class Worker
+          def start
+            logger.info "#{log_prefix} starting..."
+            logger.info "RabbitMQ Worker: Skipping consuming during test."
+            logger.debug "#{log_prefix} started"
+          end
+        end
+      end
+    end
+  end
+end
+
 describe Emque::Consuming::Adapters::RabbitMq::Worker do
   describe "#initialize" do
-    Dummy::Application.config.purge_queues_on_start = false
-    Dummy::Application.config.set_adapter(:rabbit_mq)
-    Dummy::Application.router.map do
-      topic "events" => EventsConsumer do
-        map "events.new" => "new_event"
-      end
+    before do
+      @connection = Bunny.new
+      @connection.start
+      @channel = @connection.create_channel
+      @channel.queue_delete("emque.dummy.spec")
+      @fanout = @channel.fanout("dummy.spec",
+        :durable => true,
+        :auto_delete => false
+      )
+      @queue = @channel
+        .queue("emque.dummy.spec", {
+          :durable => true,
+          :auto_delete => false,
+          :arguments => {
+            "x-dead-letter-exchange" => "dummy.error"
+          }
+        }).bind(@fanout)
+      @queue.publish(Oj.dump({
+        :metadata => {
+          :topic => "spec",
+          :type => "dummy.spec"
+        }
+      }))
+
     end
 
-    app = Dummy::Application.new
-    connection = Bunny.new
-    connection.start
-    manager = Dummy::Application.config.adapter.manager.new
-    app.start
+    after do
+      @channel.queue_delete("emque.dummy.spec")
+      @connection.close
+    end
 
-    # expect(queue.message_count).to be eq(10)
+    it "should not purge queues on start" do
+      Dummy::Application.config.purge_queues_on_start = false
+      Dummy::Application.config.set_adapter(:rabbit_mq)
+      Dummy::Application.router.map do
+        topic "spec" => SpecConsumer do; end
+      end
+      app = Dummy::Application.new
+      connection = Bunny.new
+      connection.start
+      connection.with_channel do |channel|
+        @queue = channel.queue("emque.dummy.spec", :passive => true)
+        expect(@queue.message_count).to eq(1)
+      end
+      app.start
+      sleep 0.3
+      connection.with_channel do |channel|
+        @queue = channel.queue("emque.dummy.spec", :passive => true)
+        expect(@queue.message_count).to eq(1)
+      end
+    end
 
-    # app.manager.workers.first.last.first.send(:queue).publish("tsting", :routing_key => "events")
-    # app.manager.workers.first.last.first.send(:channel).default_exchange.publish("test")
-    # app.manager.workers.first.last.first.send(:queue).message_count
+    it "should purge queues on start" do
+      Dummy::Application.config.purge_queues_on_start = true
+      Dummy::Application.config.set_adapter(:rabbit_mq)
+      Dummy::Application.router.map do
+       topic "spec" => SpecConsumer do; end
+      end
+      app = Dummy::Application.new
+      connection = Bunny.new
+      connection.start
+      connection.with_channel do |channel|
+        @queue = channel.queue("emque.dummy.spec", :passive => true)
+        expect(@queue.message_count).to eq(1)
+      end
+      app.start
+      sleep 0.3
+      connection.with_channel do |channel|
+        @queue = channel.queue("emque.dummy.spec", :passive => true)
+        expect(@queue.message_count).to eq(0)
+      end
+    end
   end
 end

spec/dummy/config/application.rb

@@ -7,14 +7,14 @@ module Emque
   module Consuming
     module Adapters
       module RabbitMq
-        def self.default_options; {}; end
+        def self.default_options; { :durable => true }; end
         def self.load; end
         def self.manager
           Emque::Consuming::Adapters::RabbitMq::Manager
         end
       end
       module TestAdapter
-        def self.default_options; {}; end
+        def self.default_options; { :durable => true }; end
         def self.load; end
         def self.manager
           Emque::Consuming::Adapters::TestAdapter::Manager

spec/dummy/consumers/events_consumer.rb → spec/dummy/consumers/spec_consumer.rb

@@ -1,6 +1,6 @@
-class EventsConsumer
+class SpecConsumer
   include Emque::Consuming.consumer
 
-  def new_event(message)
+  def test(message)
   end
 end

spec/spec_helper.rb

@@ -13,7 +13,7 @@
 require "timecop"
 require "fileutils"
 require_relative "dummy/config/application"
-require_relative "dummy/consumers/events_consumer"
+require_relative "dummy/consumers/spec_consumer"
 
 module VerifyAndResetHelpers
   def verify(object)