We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b99f4ce commit 9c59da9Copy full SHA for 9c59da9
src/rabbit_vshovel_worker.erl
@@ -190,7 +190,7 @@ terminate({shutdown, autodelete}, State = #state{name = {VHost, Name},
190
close_connections(State),
191
%% See rabbit_vshovel_dyn_worker_sup_sup:stop_child/1
192
put(vshovel_worker_autodelete, true),
193
- rabbit_runtime_parameters:clear(VHost, <<"vshovel">>, Name),
+ rabbit_runtime_parameters:clear(VHost, <<"vshovel">>, Name, ?VSHOVEL_USER),
194
rabbit_vshovel_status:remove({VHost, Name}),
195
catch Mod:terminate(DestState),
196
ok;
@@ -306,7 +306,7 @@ publish(Tag, Method, Msg, State = #state{inbound_ch = InboundChan,
306
end).
307
308
make_conn_and_chan(URIs) ->
309
- URI = lists:nth(rand_compat:uniform(length(URIs)), URIs),
+ URI = lists:nth(rand:uniform(length(URIs)), URIs),
310
{ok, AmqpParam} = amqp_uri:parse(URI),
311
{ok, Conn} = amqp_connection:start(AmqpParam),
312
link(Conn),
0 commit comments