diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-12 10:18:45 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-12 10:18:45 +0000 |
| commit | 6a5738c6025ee65865d1fc358758fb01b6be82e4 (patch) | |
| tree | ac324b2c29fe91817ef3d64ca04015a08ba6c63b | |
| parent | 0c84e4f85fa92a384646af16ec9087696c65c139 (diff) | |
| download | rabbitmq-server-6a5738c6025ee65865d1fc358758fb01b6be82e4.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_variable_queue.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 285dfcd7..5dc46f1b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1122,7 +1122,7 @@ remove(AckRequired, MsgStatus = #msg_status { index_state = IndexState, msg_store_clients = MSCState, len = Len, - persistent_count = PCount }) -> + persistent_count = PCount}) -> %% 1. Mark it delivered if necessary IndexState1 = maybe_write_delivered( IndexOnDisk andalso not IsDelivered, @@ -1151,11 +1151,11 @@ remove(AckRequired, MsgStatus = #msg_status { PCount1 = PCount - one_if(IsPersistent andalso not AckRequired), RamMsgCount1 = RamMsgCount - one_if(Msg =/= undefined), - {AckTag, State1 #vqstate { ram_msg_count = RamMsgCount1, - out_counter = OutCount + 1, - index_state = IndexState2, - len = Len - 1, - persistent_count = PCount1 }}. + {AckTag, State1 #vqstate {ram_msg_count = RamMsgCount1, + out_counter = OutCount + 1, + index_state = IndexState2, + len = Len - 1, + persistent_count = PCount1}}. purge_betas_and_deltas(LensByStore, State = #vqstate { q3 = Q3, |