Skip to content

Commit 4823d8c

Browse files
michaelklishinmergify[bot]
authored andcommitted
Shovel worker: fetch handle module from rabbit_registry
(cherry picked from commit 2a920a4)
1 parent cfaddf9 commit 4823d8c

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -55,9 +55,8 @@ init([Type, Name, Config0]) ->
5555
%% TODO It could handle errors while parsing
5656
%% (i.e. missing predeclared queues) and stop nicely
5757
%% without long stacktraces
58-
{ok, Conf} = rabbit_shovel_parameters:parse(Name,
59-
ClusterName,
60-
Config0),
58+
{ok, Mod} = rabbit_registry:lookup_module(runtime_parameter, shovel),
59+
{ok, Conf} = Mod:parse(Name, ClusterName, Config0),
6160
Conf
6261
end,
6362
?LOG_DEBUG("Initialising a Shovel ~ts of type '~ts'", [human_readable_name(Name), Type]),

0 commit comments

Comments
 (0)