diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-09-28 11:47:22 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-09-28 11:47:22 +0100 |
| commit | 3a61cb9d66fabd330f9f9dacc66cef9a7f88e645 (patch) | |
| tree | 9c37ba1667a3837d96fa7f0261e683ef5ce0fecd /src | |
| parent | 575d76eb81626877e58c6b0642eb7f60f09ab702 (diff) | |
| download | rabbitmq-server-3a61cb9d66fabd330f9f9dacc66cef9a7f88e645.tar.gz | |
lshift
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 98d08041..9af486b3 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -2333,11 +2333,11 @@ test_variable_queue_requeue(VQ0) -> {_MsgIds, VQ4} = rabbit_variable_queue:requeue(proplists:get_keys(AckMap -- SubMap), fun(X) -> X end, VQ3), - VQ5 = lists:foldl(fun (AckTag, VQN) -> - {_MsgId, VQM} = rabbit_variable_queue:requeue( - [AckTag], fun(X) -> X end, VQN), - VQM - end, VQ4, proplists:get_keys(SubMap)), + VQ5 = lists:foldl(fun (AckTag, VQN) -> + {_MsgId, VQM} = rabbit_variable_queue:requeue( + [AckTag], fun(X) -> X end, VQN), + VQM + end, VQ4, proplists:get_keys(SubMap)), VQ6 = lists:foldl(fun ({N, _}, VQN) -> {{#basic_message{}, true, AckTag, QLen}, VQM} = rabbit_variable_queue:fetch(true, VQN), |