cheburek

Author: 0exp

lib/rabbit/event_handler.rb

@@ -15,8 +15,6 @@ class Rabbit::EventHandler
   class_attribute :additional_job_configs, default: {}
 
   class << self
-    private
-
     def queue_as(queue = nil, &block)
       self.queue = queue || block
     end
@@ -25,7 +23,7 @@ def job_config(**config_opts)
       additional_job_configs.merge!(config_opts)
     end
 
-    def job_configs(**config_opts)
+    def job_configs(config_opts)
       self.additional_job_configs = config_opts
     end
   end

spec/units/rabbit/dummy/some_group.rb

@@ -14,6 +14,14 @@ class SomeSuccessfulEvent < Rabbit::EventHandler
       def call; end
     end
 
+    class SomeConfigurableEventHandler < Rabbit::EventHandler
+      queue_as { |message, arguments| "#{message.data[:hello]}_#{arguments[:type]}" }
+
+      attribute :hello
+
+      def call; end
+    end
+
     class SomeUnsuccessfulEvent < Rabbit::EventHandler
       queue_as :custom
 

spec/units/rabbit/receiving_spec.rb

@@ -239,14 +239,17 @@ def call; end
     end
 
     context "custom job configuration" do
-      let(:queue) { "custom_queue" }
       let(:job_configs) { Hash[some: :kek, pek: 123] }
-      let(:handler) { Rabbit::Handler::SomeGroup::SomeConfigurableEventHandler }
+      let(:handler)     { Rabbit::Handler::SomeGroup::SomeConfigurableEventHandler }
+      let(:queue)       { "world_some_successful_event_prepared" }
 
       before { handler.job_configs(job_configs) }
       after { handler.job_configs({}) }
 
       it "invokes job with custom config" do
+        expect_job_queue_to_be_set
+        expect_empty_handler_to_be_called
+        expect_hooks_to_be_called
         run_receive
       end
     end