summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-06-26 17:57:57 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-06-26 17:57:57 +0100
commit68729ce7d03eae11e669dd67bf1a52a143207bbe (patch)
treeb47a113a2cbd223d1f334334e183af87b742f46c
parentdb546098abcac143c531715cd4a6421f33184a12 (diff)
downloadrabbitmq-server-bug24217.tar.gz
simplifybug24217
-rw-r--r--src/rabbit_tests.erl11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl
index 8f655846..3ee71a6d 100644
--- a/src/rabbit_tests.erl
+++ b/src/rabbit_tests.erl
@@ -2199,13 +2199,12 @@ test_dropwhile(VQ0) ->
VQ4.
test_dropwhile_varying_ram_duration(VQ0) ->
- VQ1 = variable_queue_publish(false, 2, VQ0),
+ VQ1 = variable_queue_publish(false, 1, VQ0),
VQ2 = rabbit_variable_queue:set_ram_duration_target(0, VQ1),
- VQ3 = rabbit_variable_queue:set_ram_duration_target(infinity, VQ2),
- VQ4 = variable_queue_publish(false, 1, VQ3),
- VQ5 = rabbit_variable_queue:dropwhile(fun(_) -> false end, VQ4),
- {VQ6, [_AckTag]} = variable_queue_fetch(1, false, false, 3, VQ5),
- rabbit_variable_queue:dropwhile(fun(_) -> false end, VQ6).
+ VQ3 = rabbit_variable_queue:dropwhile(fun(_) -> false end, VQ2),
+ VQ4 = rabbit_variable_queue:set_ram_duration_target(infinity, VQ3),
+ VQ5 = variable_queue_publish(false, 1, VQ4),
+ rabbit_variable_queue:dropwhile(fun(_) -> false end, VQ5).
test_variable_queue_dynamic_duration_change(VQ0) ->
SegmentSize = rabbit_queue_index:next_segment_boundary(0),