diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index a540025494..d402ef97cc 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -826,11 +826,11 @@ handle_cast(send_memory_monitor_update, State) -> rabbit_memory_monitor:push_queue_duration(self(), BufSec), noreply(State#q{drain_ratio = DrainRatio1}); -handle_cast({set_bufsec_limit, BufSec}, State) -> +handle_cast({set_queue_duration, QueueDuration}, State) -> DrainRatio = State#q.drain_ratio, - DesiredQueueLength = case BufSec of + DesiredQueueLength = case QueueDuration of infinity -> infinity; - _ -> BufSec * DrainRatio#ratio.ratio * 1000000 + _ -> QueueDuration * DrainRatio#ratio.ratio * 1000000 end, %% Just to proove that something is happening. ?LOGDEBUG("Queue size is ~8p, should be ~p~n", |