diff options
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 22333f6bdf..a8b2f1f673 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -158,12 +158,8 @@ ra_machine_config(Q) when ?is_amqqueue(Q) -> {Name, _} = amqqueue:get_pid(Q), %% take the minimum value of the policy and the queue arg if present MaxLength = args_policy_lookup(<<"max-length">>, fun min/2, Q), - Overflow = args_policy_lookup(<<"overflow">>, - fun (A, B) -> - rabbit_log:info("RESOLVE ~p", [{A, B}]), - A - end , Q), - rabbit_log:info("OVERFLOW ~p ARGS ~p", [Overflow, amqqueue:get_arguments(Q)]), + %% prefer the policy defined strategy if available + Overflow = args_policy_lookup(<<"overflow">>, fun (A, _B) -> A end , Q), MaxBytes = args_policy_lookup(<<"max-length-bytes">>, fun min/2, Q), MaxMemoryLength = args_policy_lookup(<<"max-in-memory-length">>, fun min/2, Q), MaxMemoryBytes = args_policy_lookup(<<"max-in-memory-bytes">>, fun min/2, Q), |