fix concurrency initialization (#67)

Fix bug where concurrency was not initialized correctly.

CHANGELOG.md

@@ -6,6 +6,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## Unreleased
 
+## 1.5.1 - 2024-05-13
+### Changed
+- Fix bug where outbox concurrency was not being configured correctly.
+
 ## 1.5.0 - 2024-05-07
 ### Changed
 - The outbox consumer processes event batches concurrently

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    eventsimple (1.5.0)
+    eventsimple (1.5.1)
       concurrent-ruby (>= 1.2.3)
       dry-struct (~> 1.6)
       dry-types (~> 1.7)
@@ -184,7 +184,7 @@ GEM
     minitest (5.22.2)
     mutex_m (0.2.0)
     nenv (0.3.0)
-    net-imap (0.4.10)
+    net-imap (0.4.11)
       date
       net-protocol
     net-pop (0.1.2)

README.md

@@ -302,8 +302,7 @@ module UserComponent
 
     identitfier 'UserComponent::Consumer'
     consumes_event UserEvent
-    processor EventProcessor
-    concurrency 5 # default is 5
+    processor EventProcessor, concurrency: 5
   end
 end
 ```

lib/eventsimple/outbox/consumer.rb

@@ -30,15 +30,12 @@ def consumes_event(event_klass)
         self._event_klass = event_klass
       end
 
-      def processor(processor_klass)
+      def processor(processor_klass, concurrency: 5)
+        self._concurrency = concurrency
         self._processor_klass = processor_klass
         self._processor_pool = _concurrency.times.map { processor_klass.new }
       end
 
-      def concurrency(concurrency)
-        self._concurrency = concurrency
-      end
-
       def start # rubocop:disable Metrics/AbcSize
         Signal.trap('INT') do
           self.stop_consumer = true

lib/eventsimple/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Eventsimple
-  VERSION = '1.5.0'
+  VERSION = '1.5.1'
 end

spec/dummy/spec/components/user_component/consumer_spec.rb

@@ -62,6 +62,7 @@
 
       run_consumer
 
+      expect(described_class._processor_pool.size).to eq(5)
       expect(described_class._processor_pool[0]).to have_received(:call).once
       expect(described_class._processor_pool[1]).to have_received(:call).once
       expect(described_class._processor_pool[2]).to have_received(:call).once