Add default config for exclusive consumer

jondot · Mar 25, 2019 · b81b6a8 · b81b6a8
1 parent 6b7fdeb
commit b81b6a8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/lib/sneakers/configuration.rb b/lib/sneakers/configuration.rb
@@ -41,6 +41,7 @@ class Configuration
       :threads            => 10,
       :share_threads      => false,
       :ack                => true,
+      :exclusive          => false,
       :heartbeat          => 30,
       :hooks              => {},
       :exchange           => 'sneakers',

diff --git a/spec/sneakers/worker_spec.rb b/spec/sneakers/worker_spec.rb
@@ -18,6 +18,7 @@ class DummyWorker
                :arguments => { 'x-arg' => 'value' }
              },
              :ack => false,
+             :exclusive => true,
              :threads => 50,
              :prefetch => 40,
              :exchange => 'dummy',
@@ -177,6 +178,7 @@ def work(msg)
           :threads => 10,
           :share_threads => false,
           :ack => true,
+          :exclusive => false,
           :amqp => "amqp://guest:guest@localhost:5672",
           :vhost => "/",
           :exchange => "sneakers",
@@ -215,6 +217,7 @@ def work(msg)
           :threads => 50,
           :share_threads => false,
           :ack => false,
+          :exclusive => true,
           :amqp => "amqp://guest:guest@localhost:5672",
           :vhost => "/",
           :exchange => "dummy",
@@ -253,6 +256,7 @@ def work(msg)
           :threads => 10,
           :share_threads => false,
           :ack => true,
+          :exclusive => false,
           :amqp => "amqp://guest:guest@localhost:5672",
           :vhost => "/",
           :exchange => "sneakers",