lib/reactor/workers/concerns/configuration.rb in reactor-0.18.0 vs lib/reactor/workers/concerns/configuration.rb in reactor-0.19.0

@@ -18,16 +18,21 @@
 
         def perform_where_needed(data)
           if deprecated
             return
           elsif delay > 0
-            perform_in(delay, data)
+            event_queue.perform_in(delay, data)
           elsif async
-            perform_async(data)
+            event_queue.perform_async(data)
           else
             new.perform(data)
           end
           source
+        end
+
+        def event_queue
+          queue_override = ENV['REACTOR_QUEUE']
+          queue_override.present? ? set(queue: queue_override) : self
         end
       end
 
       def configured?
         self.class.configured?
\ No newline at end of file