Rename concurrency option to be compatible with Commanded 1.4

fabriziosestito · Jul 6, 2022 · e8faff2 · e8faff2
1 parent 0a930fd
commit e8faff2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/lib/commanded/event_store/adapters/spear/subscription.ex b/lib/commanded/event_store/adapters/spear/subscription.ex
@@ -20,7 +20,7 @@ defmodule Commanded.EventStore.Adapters.Spear.Subscription do
     :serializer,
     :stream,
     :start_from,
-    :subscriber_max_count,
+    :concurrency_limit,
     :subscriber,
     :subscriber_ref,
     :subscription,
@@ -38,7 +38,7 @@ defmodule Commanded.EventStore.Adapters.Spear.Subscription do
       serializer: serializer,
       subscriber: subscriber,
       start_from: Keyword.get(opts, :start_from),
-      subscriber_max_count: Keyword.get(opts, :subscriber_max_count, 1),
+      concurrency_limit: Keyword.get(opts, :concurrency_limit, 1),
       retry_interval: subscription_retry_interval()
     }
 
@@ -168,11 +168,11 @@ defmodule Commanded.EventStore.Adapters.Spear.Subscription do
       name: name,
       stream: stream,
       start_from: start_from,
-      subscriber_max_count: subscriber_max_count
+      concurrency_limit: concurrency_limit
     } = state
 
     settings = %Spear.PersistentSubscription.Settings{
-      max_subscriber_count: subscriber_max_count,
+      max_subscriber_count: concurrency_limit,
       message_timeout: 10_000,
       resolve_links?: true
     }

diff --git a/lib/commanded/event_store/adapters/spear/subscriptions_supervisor.ex b/lib/commanded/event_store/adapters/spear/subscriptions_supervisor.ex
@@ -47,11 +47,11 @@ defmodule Commanded.EventStore.Adapters.Spear.SubscriptionsSupervisor do
         {:ok, pid}
 
       {:error, {:already_started, _pid}} ->
-        case Keyword.get(opts, :subscriber_max_count) do
+        case Keyword.get(opts, :concurrency_limit) do
           nil ->
             {:error, :subscription_already_exists}
 
-          subscriber_max_count when index < subscriber_max_count - 1 ->
+          concurrency_limit when index < concurrency_limit - 1 ->
             start_subscription(
               event_store,
               conn,