diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-08-12 12:26:06 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-08-12 12:26:06 +0100 |
| commit | 0f883e515008a52dd6ebf61eb428632c581d1423 (patch) | |
| tree | 5363a67e124e4a3cb1d82ded6d0bc7eca65d1b9b | |
| parent | d6416a72d485c74c05dd0c1bb0d2cd9235ea9c60 (diff) | |
| download | rabbitmq-server-git-0f883e515008a52dd6ebf61eb428632c581d1423.tar.gz | |
Add requeue order test
| -rw-r--r-- | src/rabbit_tests.erl | 30 |
1 files changed, 29 insertions, 1 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 2e4544114a..f2b6810e98 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -2170,9 +2170,37 @@ test_variable_queue() -> fun test_variable_queue_all_the_bits_not_covered_elsewhere2/1, fun test_dropwhile/1, fun test_dropwhile_varying_ram_duration/1, - fun test_variable_queue_ack_limiting/1]], + fun test_variable_queue_ack_limiting/1, + fun test_variable_queue_requeue/1]], passed. +test_variable_queue_requeue(VQ0) -> + Count = 20000, + VQ1 = rabbit_variable_queue:set_ram_duration_target(0, VQ0), + VQ2 = variable_queue_publish(true, Count, VQ1), + {VQ3, AckMap} = lists:foldl(fun (N, {VQN, AckTags}) -> + {{#basic_message{}, false, AckTag, _}, VQM} = + rabbit_variable_queue:fetch(true, VQN), + {VQM, [{AckTag, N} | AckTags]} + end, {VQ2, []}, lists:seq(0, Count - 1)), + SubMap = lists:filter(fun ({_AckTag, N}) -> + N rem 500 =:= 0 + end, AckMap), + {_MsgIds, VQ4} = + rabbit_variable_queue:requeue(proplists:get_keys(AckMap -- SubMap), + fun(X) -> X end, VQ3), + {_MsgIds2, VQ5} = + rabbit_variable_queue:requeue(proplists:get_keys(SubMap), + fun(X) -> X end, VQ4), + VQ6 = lists:foldl(fun ({N, _}, VQN) -> + {{#basic_message{}, true, AckTag, QLen}, VQM} = + rabbit_variable_queue:fetch(true, VQN), + N = proplists:get_value(AckTag, AckMap), + QLen = Count - N - 1, + VQM + end, VQ5, lists:reverse(AckMap)), + VQ6. + test_variable_queue_ack_limiting(VQ0) -> %% start by sending in a bunch of messages Len = 1024, |