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) ->
753
753
end .
754
754
755
755
maybe_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 )),
757
760
758
761
RelevantKeys = maps :keys (NewPolicyConfig ),
759
762
CurrentPolicyConfig = maps :with (RelevantKeys , CurrentConfig ),
760
763
761
764
ShouldUpdate = NewPolicyConfig =/= CurrentPolicyConfig ,
762
765
case ShouldUpdate of
763
766
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 ))]),
765
769
policy_changed (Q ),
766
770
ok ;
767
771
false -> ok
You can’t perform that action at this time.
0 commit comments