Skip to content

Commit c3b064c

Browse files
Merge pull request #14648 from rabbitmq/mk-dpc-shovel-fetch-parameters-module-from-registry
Shovel worker: fetch handler module from rabbit_registry
2 parents 270c43f + 2a920a4 commit c3b064c

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)