summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-07-21 06:05:07 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-07-21 06:05:07 +0100
commit508fa90dec361c4dd412c87b1c0d0f28a392cfc3 (patch)
treedb85a43e702e30beb35c1c9038cc1ff7172ce664
parent82afd48cfc995368ed78844f37ac6a523eb30283 (diff)
downloadrabbitmq-server-508fa90dec361c4dd412c87b1c0d0f28a392cfc3.tar.gz
cosmetic
-rw-r--r--src/rabbit_tests.erl11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl
index 59d881bb..7d03ecbd 100644
--- a/src/rabbit_tests.erl
+++ b/src/rabbit_tests.erl
@@ -1844,13 +1844,14 @@ variable_queue_wait_for_shuffling_end(VQ) ->
end.
test_variable_queue_all_the_bits_not_covered_elsewhere1(VQ0) ->
- Count = 2*rabbit_queue_index:next_segment_boundary(0),
+ Count = 2 * rabbit_queue_index:next_segment_boundary(0),
VQ1 = variable_queue_publish(true, Count, VQ0),
VQ2 = variable_queue_publish(false, Count, VQ1),
VQ3 = rabbit_variable_queue:set_ram_duration_target(0, VQ2),
- {VQ4, _AckTags} =
- variable_queue_fetch(Count, true, false, Count + Count, VQ3),
- {VQ5, _AckTags1} = variable_queue_fetch(Count, false, false, Count, VQ4),
+ {VQ4, _AckTags} = variable_queue_fetch(Count, true, false,
+ Count + Count, VQ3),
+ {VQ5, _AckTags1} = variable_queue_fetch(Count, false, false,
+ Count, VQ4),
_VQ6 = rabbit_variable_queue:terminate(VQ5),
VQ7 = rabbit_variable_queue:init(test_queue(), true, true),
{{_Msg1, true, _AckTag1, Count1}, VQ8} =
@@ -1873,7 +1874,7 @@ test_variable_queue_all_the_bits_not_covered_elsewhere2(VQ0) ->
VQ8.
test_queue_recover() ->
- Count = 2*rabbit_queue_index:next_segment_boundary(0),
+ Count = 2 * rabbit_queue_index:next_segment_boundary(0),
TxID = rabbit_guid:guid(),
{new, #amqqueue { pid = QPid, name = QName }} =
rabbit_amqqueue:declare(test_queue(), true, false, [], none),