diff options
| author | Rob Harrop <rharrop@vmware.com> | 2010-09-16 11:43:06 +0100 |
|---|---|---|
| committer | Rob Harrop <rharrop@vmware.com> | 2010-09-16 11:43:06 +0100 |
| commit | b09ab1ad0d284a9e6741d3d9a9b102a190b87ea7 (patch) | |
| tree | 91243ecb74d583ef2e44a502271dcdcd2f154075 /src | |
| parent | 934c2fb0b45c08617fb2c19f8eefb17662b538ba (diff) | |
| download | rabbitmq-server-git-b09ab1ad0d284a9e6741d3d9a9b102a190b87ea7.tar.gz | |
fixed bug in persistent_guids vq
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index aee8d47b36..15167af0b3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -613,8 +613,8 @@ tx_commit(Txn, Fun, MsgPropsFun, State = #vqstate { durable = IsDurable }) -> #tx { pending_acks = AckTags, pending_messages = Pubs } = lookup_tx(Txn), erase_tx(Txn), F = fun({Msg, MsgProperties}) -> - {Msg, MsgPropsFun(MsgProperties)} - end, + {Msg, MsgPropsFun(MsgProperties)} + end, PubsProcessed = lists:map(F, Pubs), PubsOrdered = lists:reverse(PubsProcessed), AckTags1 = lists:append(AckTags), @@ -832,7 +832,8 @@ store_tx(Txn, Tx) -> put({txn, Txn}, Tx). erase_tx(Txn) -> erase({txn, Txn}). persistent_guids(Pubs) -> - [Guid || #basic_message { guid = Guid, is_persistent = true } <- Pubs]. + [Guid || + {#basic_message { guid = Guid, is_persistent = true }, _MsgProps} <- Pubs]. betas_from_index_entries(List, TransientThreshold, IndexState) -> {Filtered, Delivers, Acks} = |