Skip to content

Commit c95d318

Browse files
committed
Keep StartMode argument for mixed-version compatibility
1 parent 1bb7c47 commit c95d318

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

deps/rabbit/src/rabbit_amqqueue_sup.erl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,18 +9,18 @@
99

1010
-behaviour(supervisor).
1111

12-
-export([start_link/1]).
12+
-export([start_link/2]).
1313

1414
-export([init/1]).
1515

1616
-include_lib("rabbit_common/include/rabbit.hrl").
1717

1818
%%----------------------------------------------------------------------------
1919

20-
-spec start_link(amqqueue:amqqueue()) ->
20+
-spec start_link(amqqueue:amqqueue(), any()) ->
2121
{'ok', pid(), pid()}.
2222

23-
start_link(Q) ->
23+
start_link(Q, _StartMode) ->
2424
Marker = spawn_link(fun() -> receive stop -> ok end end),
2525
StartMFA = {rabbit_amqqueue_process, start_link, [Q, Marker]},
2626
ChildSpec = #{id => rabbit_amqqueue,

deps/rabbit/src/rabbit_amqqueue_sup_sup.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ start_link() ->
3232
start_queue_process(Node, Q) ->
3333
#resource{virtual_host = VHost} = amqqueue:get_name(Q),
3434
{ok, Sup} = find_for_vhost(VHost, Node),
35-
{ok, _SupPid, QPid} = supervisor:start_child(Sup, [Q]),
35+
{ok, _SupPid, QPid} = supervisor:start_child(Sup, [Q, declare]),
3636
QPid.
3737

3838
init([]) ->

0 commit comments

Comments
 (0)