DSL

umbrellio · Oct 11, 2024 · 6de4277 · 6de4277
1 parent 0f600a0
commit 6de4277
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/lib/rabbit/event_handler.rb b/lib/rabbit/event_handler.rb
@@ -12,14 +12,22 @@ class Rabbit::EventHandler
 
   class_attribute :queue
   class_attribute :ignore_queue_conversion, default: false
-  class_attribute :job_configs, default: {}
+  class_attribute :additional_job_configs, default: {}
 
   class << self
     private
 
     def queue_as(queue = nil, &block)
       self.queue = queue || block
     end
+
+    def job_config(**config_opts)
+      self.additional_job_configs.merge!(config_opts)
+    end
+
+    def job_configs(**config_opts)
+      self.additional_job_configs = config_opts
+    end
   end
 
   def initialize(message)

diff --git a/lib/rabbit/receiving/receive.rb b/lib/rabbit/receiving/receive.rb
@@ -57,7 +57,7 @@ def queue
   end
 
   def job_configs
-    queue.handler.job_configs
+    queue.handler.additional_job_configs
   end
 
   def queue_name