Skip to content

Commit 3145fed

Browse files
committed
Always register Khepri projections on startup
Backported from a change made on main/4.2: 63313e1 Without this, we can't fix the topic exchange leak
1 parent 949e6a8 commit 3145fed

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -312,12 +312,7 @@ init(IsVirgin) ->
312312
"local Khepri-based " ?RA_FRIENDLY_NAME " member is caught "
313313
"up to the Raft cluster leader", [],
314314
#{domain => ?RMQLOG_DOMAIN_DB}),
315-
ok ?= case IsVirgin of
316-
true ->
317-
register_projections();
318-
false ->
319-
ok
320-
end,
315+
ok ?= register_projections(),
321316
%% Delete transient queues on init.
322317
%% Note that we also do this in the
323318
%% `rabbit_amqqueue:on_node_down/1' callback. We must try this

0 commit comments

Comments
 (0)