diff options
| author | Jerry Kuch <jerryk@vmware.com> | 2011-03-07 13:57:03 -0800 |
|---|---|---|
| committer | Jerry Kuch <jerryk@vmware.com> | 2011-03-07 13:57:03 -0800 |
| commit | f8a57e254e48ba38b42c1fae1bd358b16c809d74 (patch) | |
| tree | 74de5a12b564c841e6935dcff09fadafdae801d0 | |
| parent | 8b3605eca1a291a28a5cd4ffee5192d5d22aad9d (diff) | |
| download | rabbitmq-server-f8a57e254e48ba38b42c1fae1bd358b16c809d74.tar.gz | |
Wire up dropwhile to internal_dropwhile; spotty testing above internal_dropwhile presently.
| -rw-r--r-- | src/rabbit_mysql_queue.erl | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/rabbit_mysql_queue.erl b/src/rabbit_mysql_queue.erl index 09ae28d2..fba4f35e 100644 --- a/src/rabbit_mysql_queue.erl +++ b/src/rabbit_mysql_queue.erl @@ -396,15 +396,11 @@ publish_delivered(true, dropwhile(Pred, S) -> rabbit_log:info("dropwhile(~n ~p,~n ~p) ->", [Pred, S]), - %% {atomic, {_, Result}} = - %% mnesia:transaction(fun () -> {Atom, RS} = internal_dropwhile(Pred, S), - %% save(RS), - %% {Atom, RS} - %% end), mysql_helper:begin_mysql_transaction(), - Result = utterly_bogus_placeholder_result, + {_, RS} = internal_dropwhile(Pred, S), + save(RS), mysql_helper:commit_mysql_transaction(), - rabbit_log:info("dropwhile ->~n ~p", [Result]), + rabbit_log:info("dropwhile ->~n ~p", [RS]), Result. %%############################################################################# |