diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-06 18:34:54 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-06 18:34:54 +0100 |
| commit | 7d15df90953e33d7e7c20b5268a63fa5df4607b4 (patch) | |
| tree | 637cc7c3b3a002e0f994cce07ee3a5d450402255 | |
| parent | 7321cd2ffca115b78cd6acb7f6548e64a7e4e8a9 (diff) | |
| download | rabbitmq-server-7d15df90953e33d7e7c20b5268a63fa5df4607b4.tar.gz | |
cosmetics
| -rw-r--r-- | src/rabbit_variable_queue.erl | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 608e2dcd..e74447e2 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -678,7 +678,7 @@ tx_commit(Txn, Fun, MsgPropsFun, State = #vqstate { durable = IsDurable }) -> a(case IsDurable andalso HasPersistentPubs of true -> ok = rabbit_msg_store:sync( ?PERSISTENT_MSG_STORE, PersistentGuids, - msg_store_callback(PersistentGuids,Pubs, AckTags1, + msg_store_callback(PersistentGuids, Pubs, AckTags1, Fun, MsgPropsFun)), State; false -> tx_commit_post_msg_store(HasPersistentPubs, Pubs, AckTags1, @@ -888,9 +888,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 }, - _MsgProps} <- Pubs]. + [Guid || {#basic_message { guid = Guid, is_persistent = true }, _MsgProps} + <- Pubs]. betas_from_index_entries(List, TransientThreshold, IndexState) -> {Filtered, Delivers, Acks} = @@ -1337,9 +1336,7 @@ fetch_from_q3(State = #vqstate { {empty, _Q3} -> {empty, State}; {{value, _IndexOnDisk, MsgStatus}, Q3a} -> - - State1 = State #vqstate { q3 = Q3a}, - + State1 = State #vqstate { q3 = Q3a }, State2 = case {bpqueue:is_empty(Q3a), 0 == DeltaCount} of {true, true} -> |