diff options
Diffstat (limited to 'src/rabbit_backing_queue.erl')
| -rw-r--r-- | src/rabbit_backing_queue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue.erl b/src/rabbit_backing_queue.erl index eac1db2f..d69a6c3b 100644 --- a/src/rabbit_backing_queue.erl +++ b/src/rabbit_backing_queue.erl @@ -152,8 +152,8 @@ %% Is my queue empty? -callback is_empty(state()) -> boolean(). -%% How many pending acks do we have? --callback pending_ack(state()) -> non_neg_integer(). +%% What's the queue depth, where depth = length + number of pending acks +-callback depth(state()) -> non_neg_integer(). %% For the next three functions, the assumption is that you're %% monitoring something like the ingress and egress rates of the @@ -215,7 +215,7 @@ behaviour_info(callbacks) -> {delete_and_terminate, 2}, {purge, 1}, {publish, 4}, {publish_delivered, 5}, {drain_confirmed, 1}, {dropwhile, 3}, {fetch, 2}, {ack, 2}, {fold, 3}, {requeue, 2}, {len, 1}, - {is_empty, 1}, {pending_ack, 1}, {set_ram_duration_target, 2}, + {is_empty, 1}, {depth, 1}, {set_ram_duration_target, 2}, {ram_duration, 1}, {needs_timeout, 1}, {timeout, 1}, {handle_pre_hibernate, 1}, {status, 1}, {invoke, 3}, {is_duplicate, 2}, {discard, 3}]; |