Skip to content

Commit 4e30c2a

Browse files
Resolve a conflict (#9796)
1 parent 6ccea5b commit 4e30c2a

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup_sup.erl

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -83,18 +83,11 @@ stop_child({VHost, ShovelName} = Name) ->
8383
%% See rabbit_shovel_worker:terminate/2
8484

8585
cleanup_specs() ->
86-
<<<<<<< HEAD
87-
SpecsSet = sets:from_list([element(1, S) || S <- mirrored_supervisor:which_children(?SUPERVISOR)]),
88-
ParamsSet = sets:from_list(rabbit_runtime_parameters:list_component(<<"shovel">>)),
89-
F = fun(Spec, ok) ->
90-
_ = mirrored_supervisor:delete_child(?SUPERVISOR, Spec),
91-
=======
9286
SpecsSet = sets:from_list([element(2, element(1, S)) || S <- mirrored_supervisor:which_children(?SUPERVISOR)]),
9387
ParamsSet = sets:from_list([ {proplists:get_value(vhost, S), proplists:get_value(name, S)}
9488
|| S <- rabbit_runtime_parameters:list_component(<<"shovel">>) ]),
9589
F = fun(Name, ok) ->
9690
_ = mirrored_supervisor:delete_child(?SUPERVISOR, id(Name)),
97-
>>>>>>> 015be9336c (Speed up shovel start and cleanup)
9891
ok
9992
end,
10093
ok = sets:fold(F, ok, sets:subtract(SpecsSet, ParamsSet)).

0 commit comments

Comments
 (0)