diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-07 18:32:13 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-09-07 18:32:13 +0200 |
| commit | fe4c7980f3fb06a2cdbd3ce3c9a60a41aa42ae1c (patch) | |
| tree | e2ccc49e051a249a543b8154f998cd44d5e418a4 /src | |
| parent | bb515df0ea599bcf2dfd418117cbcb38a85cec6f (diff) | |
| download | rabbitmq-server-git-fe4c7980f3fb06a2cdbd3ce3c9a60a41aa42ae1c.tar.gz | |
updates comment
Diffstat (limited to 'src')
| -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 7ed6a00c5a..0934a4651b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -533,9 +533,9 @@ terminate(_Reason, State) -> %% the only difference between purge and delete is that delete also %% needs to delete everything that's been delivered and not ack'd. delete_and_terminate(_Reason, State) -> - %% There is no need to interact with qi at all - which we do as - %% part of 'purge' and 'purge_pending_ack', other than deleting - %% it. + %% Normally when we purge messages we interact with the qi by + %% issues delivers and acks for every purged message. In this case + %% we don't need to do that, so we just delete the qi. State1 = purge_and_index_reset(State), State2 = #vqstate { msg_store_clients = {MSCStateP, MSCStateT} } = purge_pending_ack_delete_and_terminate(State1), |