Skip to content

Commit be450bd

Browse files
Merge pull request #9785 from rabbitmq/faster-shovel-start
Speed up shovel start
2 parents 20b3179 + 015be93 commit be450bd

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup_sup.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,8 @@ stop_child({VHost, ShovelName} = Name) ->
8484

8585
cleanup_specs() ->
8686
SpecsSet = sets:from_list([element(2, element(1, S)) || S <- mirrored_supervisor:which_children(?SUPERVISOR)]),
87-
ParamsSet = sets:from_list(rabbit_runtime_parameters:list_component(<<"shovel">>)),
87+
ParamsSet = sets:from_list([ {proplists:get_value(vhost, S), proplists:get_value(name, S)}
88+
|| S <- rabbit_runtime_parameters:list_component(<<"shovel">>) ]),
8889
F = fun(Name, ok) ->
8990
_ = mirrored_supervisor:delete_child(?SUPERVISOR, id(Name)),
9091
ok

0 commit comments

Comments
 (0)