Make sure Kelvin.InOrderSubscription is loaded

NFIBrokerage · Jun 26, 2024 · b9f78c1 · b9f78c1
1 parent d5f65b5
commit b9f78c1
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/beeline/topology/stage_supervisor.ex b/lib/beeline/topology/stage_supervisor.ex
@@ -60,7 +60,11 @@ defmodule Beeline.Topology.StageSupervisor do
   # coveralls-ignore-start
   defp producer_module(_, true = _test_mode?), do: Beeline.DummyProducer
   # coveralls-ignore-stop
-  defp producer_module(:kelvin, _), do: Kelvin.InOrderSubscription
+  defp producer_module(:kelvin, _) do
+    Code.ensure_loaded!(Kelvin.InOrderSubscription)
+    Kelvin.InOrderSubscription
+  end
+
   defp producer_module(:volley, _), do: Volley.InOrderSubscription
   defp producer_module(:dummy, _), do: Beeline.DummyProducer