From b9f78c1e88708c02b7366897342a82be2ef9ab62 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sr=C4=91an=20Svrdlan?= Date: Wed, 26 Jun 2024 14:49:22 +0200 Subject: [PATCH] Make sure Kelvin.InOrderSubscription is loaded --- lib/beeline/topology/stage_supervisor.ex | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/lib/beeline/topology/stage_supervisor.ex b/lib/beeline/topology/stage_supervisor.ex index f44e056..9b18bfc 100644 --- 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