diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-05-29 15:45:54 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-05-29 15:45:54 +0100 |
| commit | 548f560d55de9f6bb0e584f0366e34eb9e2f9126 (patch) | |
| tree | 2597312585178b338129a655abf4623baebd3a63 | |
| parent | d84242c9c8cd4c57a00d7be0d4f669e38e6386ac (diff) | |
| download | rabbitmq-server-git-548f560d55de9f6bb0e584f0366e34eb9e2f9126.tar.gz | |
Dehydrate prospective betas on requeue
| -rw-r--r-- | src/rabbit_variable_queue.erl | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index f7c6c7295a..5b39c2c61d 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1363,11 +1363,8 @@ publish_alpha(MsgStatus, State) -> {MsgStatus, inc_ram_msg_count(State)}. publish_beta(MsgStatus, State) -> - {#msg_status { msg = Msg} = MsgStatus1, - #vqstate { ram_msg_count = RamMsgCount } = State1} = - maybe_write_to_disk(true, false, MsgStatus, State), - {MsgStatus1, State1 #vqstate { - ram_msg_count = RamMsgCount + one_if(Msg =/= undefined) }}. + {MsgStatus1, State1} = maybe_write_to_disk(true, false, MsgStatus, State), + {m(trim_msg_status(MsgStatus1)), State1}. %% Rebuild queue, inserting sequence ids to maintain ordering queue_merge(SeqIds, Q, MsgIds, Limit, PubFun, State) -> |