diff options
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 22829765..98c45717 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -19,7 +19,7 @@ -export([init/3, terminate/2, delete_and_terminate/2, purge/1, publish/4, publish_delivered/5, drain_confirmed/1, dropwhile/3, fetch/2, ack/2, requeue/2, len/1, is_empty/1, - pending_ack/1, set_ram_duration_target/2, ram_duration/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, multiple_routing_keys/0, fold/3]). @@ -681,8 +681,8 @@ len(#vqstate { len = Len }) -> Len. is_empty(State) -> 0 == len(State). -pending_ack(#vqstate { pending_ack = Ack }) -> - gb_trees:size(Ack). +depth(State = #vqstate { pending_ack = Ack }) -> + len(State) + gb_trees:size(Ack). set_ram_duration_target( DurationTarget, State = #vqstate { |