Skip to content

Commit 65babdb

Browse files
committed
Only remove durable bindings for durable queues.
Non-durable queues and bindings are not on disk anyways. This should be changes when moving to feature flags.
1 parent 13646d7 commit 65babdb

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

src/rabbit_binding.erl

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -256,12 +256,7 @@ remove(Src, Dst, B, ActingUser) ->
256256
remove_default_exchange_binding_rows_of(Dst = #resource{}) ->
257257
case rabbit_binding:implicit_for_destination(Dst) of
258258
[Binding] ->
259-
mnesia:dirty_delete(rabbit_route, Binding),
260-
mnesia:dirty_delete(rabbit_durable_route, Binding),
261-
mnesia:dirty_delete(rabbit_semi_durable_route, Binding),
262-
263-
RevBinding = rabbit_binding:reverse_binding(Binding),
264-
mnesia:dirty_delete(rabbit_reverse_route, RevBinding);
259+
mnesia:dirty_delete(rabbit_durable_route, Binding);
265260
_ ->
266261
%% no binding to remove or
267262
%% a competing tx has beaten us to it?

src/rabbit_upgrade_functions.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -659,7 +659,7 @@ exchange_options(Table) ->
659659
operator_policy, decorators, options]).
660660

661661
remove_explicit_default_exchange_bindings() ->
662-
Tab = rabbit_queue,
662+
Tab = rabbit_durable_queue,
663663
rabbit_table:wait([Tab]),
664664
%% Default exchange bindings are now implicit
665665
%% (not stored in the route tables).

0 commit comments

Comments
 (0)