lib/pwwka/tasks.rb in pwwka-0.14.0 vs lib/pwwka/tasks.rb in pwwka-0.15.0

@@ -4,8 +4,10 @@
     raise "HANDLER_KLASS must be set" unless ENV['HANDLER_KLASS']
     raise "QUEUE_NAME must be set" unless ENV['QUEUE_NAME']
     handler_klass = ENV['HANDLER_KLASS'].constantize
     queue_name    = "#{ENV['QUEUE_NAME']}_#{Rails.env}"
     routing_key   = ENV['ROUTING_KEY'] || "#.#"
-    Pwwka::Receiver.subscribe(handler_klass, queue_name, routing_key: routing_key)
+    prefetch = ENV['PREFETCH'] || Pwwka.configuration.default_prefetch
+
+    Pwwka::Receiver.subscribe(handler_klass, queue_name, routing_key: routing_key, prefetch: prefetch)
   end
 end