File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -753,15 +753,19 @@ system_recover(quorum_queues) ->
753753 end .
754754
755755maybe_apply_policies (Q , #{config := CurrentConfig }) ->
756- NewPolicyConfig = gather_policy_config (Q , false ),
756+ % % delivery_limit can't be updated from a policy and thus has to be
757+ % % excluded from the comparison
758+ NewPolicyConfig = maps :without ([delivery_limit ],
759+ gather_policy_config (Q , false )),
757760
758761 RelevantKeys = maps :keys (NewPolicyConfig ),
759762 CurrentPolicyConfig = maps :with (RelevantKeys , CurrentConfig ),
760763
761764 ShouldUpdate = NewPolicyConfig =/= CurrentPolicyConfig ,
762765 case ShouldUpdate of
763766 true ->
764- ? LOG_DEBUG (" Re-applying policies to ~ts " , [rabbit_misc :rs (amqqueue :get_name (Q ))]),
767+ ? LOG_DEBUG (" Re-applying policies for ~ts " ,
768+ [rabbit_misc :rs (amqqueue :get_name (Q ))]),
765769 policy_changed (Q ),
766770 ok ;
767771 false -> ok
You can’t perform that action at this time.
0 commit comments