diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 23:51:51 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 23:51:51 +0000 |
| commit | 82aabb2b759fa58403f030a24bf8f6b9382e9c6a (patch) | |
| tree | d7fa98d11c3157cf2b06a8c39f347ebc2d24044d /src | |
| parent | fe99c0f21a1f2207f21ce2890c1b9857aaa5d6c7 (diff) | |
| download | rabbitmq-server-git-82aabb2b759fa58403f030a24bf8f6b9382e9c6a.tar.gz | |
add test for invoking bq:fold when messages are on disk
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_tests.erl | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 096f949061..983abf29e6 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -2300,6 +2300,7 @@ test_variable_queue() -> fun test_variable_queue_partial_segments_delta_thing/1, fun test_variable_queue_all_the_bits_not_covered_elsewhere1/1, fun test_variable_queue_all_the_bits_not_covered_elsewhere2/1, + fun test_variable_queue_fold_msg_on_disk/1, fun test_dropwhile/1, fun test_dropwhile_varying_ram_duration/1, fun test_variable_queue_ack_limiting/1, @@ -2515,6 +2516,12 @@ test_variable_queue_all_the_bits_not_covered_elsewhere2(VQ0) -> {empty, VQ8} = rabbit_variable_queue:fetch(false, VQ7), VQ8. +test_variable_queue_fold_msg_on_disk(VQ0) -> + VQ1 = variable_queue_publish(true, 1, VQ0), + {VQ2, AckTags} = variable_queue_fetch(1, true, false, 1, VQ1), + VQ3 = rabbit_variable_queue:fold(fun (_M, _A) -> ok end, VQ2, AckTags), + VQ3. + test_queue_recover() -> Count = 2 * rabbit_queue_index:next_segment_boundary(0), {new, #amqqueue { pid = QPid, name = QName } = Q} = |