diff --git a/lib/exq/dequeue/local.ex b/lib/exq/dequeue/local.ex index c92293f2..0f4f0091 100644 --- a/lib/exq/dequeue/local.ex +++ b/lib/exq/dequeue/local.ex @@ -6,7 +6,7 @@ defmodule Exq.Dequeue.Local do end @impl true - def init(%{queue: queue}, options) do + def init(_, options) do {:ok, %State{max: Keyword.fetch!(options, :concurrency)}} end