diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2015-09-08 19:27:22 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2015-09-08 19:27:22 +0300 |
| commit | d9c9e16d2e52fe4300af5b7a840c01285face51c (patch) | |
| tree | 92194734cf701296eab5a693e60136d74ac023c4 | |
| parent | e0a30b48000abac998df455f416e8003aa0e2bd4 (diff) | |
| download | rabbitmq-server-git-d9c9e16d2e52fe4300af5b7a840c01285face51c.tar.gz | |
Inline
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index a3b0ee720b..62fa483056 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1319,13 +1319,11 @@ remove(AckRequired, MsgStatus = #msg_status { %% and an ack to the queue index for every message that's being %% removed, while the later just resets the queue index state. purge_when_pending_acks(State) -> - AfterFun = process_delivers_and_acks_fun(deliver_and_ack), - State1 = purge1(AfterFun, State), + State1 = purge1(process_delivers_and_acks_fun(deliver_and_ack), State), a(State1). purge_and_index_reset(State) -> - AfterFun = process_delivers_and_acks_fun(none), - State1 = purge1(AfterFun, State), + State1 = purge1(process_delivers_and_acks_fun(none), State), a(reset_qi_state(State1)). %% This function removes messages from each of {q1, q2, q3, q4}. |