From 4823d8c45c7644966c35f918ffe6d23abb035c38 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Tue, 30 Sep 2025 11:38:53 -0400 Subject: [PATCH] Shovel worker: fetch handle module from rabbit_registry (cherry picked from commit 2a920a4a327b96f8bd0fbfd0ffdfcb291e119268) --- deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl b/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl index df7bda6191e3..18ccf267789d 100644 --- a/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl +++ b/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl @@ -55,9 +55,8 @@ init([Type, Name, Config0]) -> %% TODO It could handle errors while parsing %% (i.e. missing predeclared queues) and stop nicely %% without long stacktraces - {ok, Conf} = rabbit_shovel_parameters:parse(Name, - ClusterName, - Config0), + {ok, Mod} = rabbit_registry:lookup_module(runtime_parameter, shovel), + {ok, Conf} = Mod:parse(Name, ClusterName, Config0), Conf end, ?LOG_DEBUG("Initialising a Shovel ~ts of type '~ts'", [human_readable_name(Name), Type]),