diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-17 15:02:29 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-17 15:02:29 +0100 |
| commit | 3d4e3704f0547bc90ac0561418899dd98bdd2148 (patch) | |
| tree | 81f31dad99059ce50d2f08bb3f42e02377593a56 | |
| parent | c651b112e4813147bbbf17297057b9f8e6309749 (diff) | |
| download | rabbitmq-server-git-3d4e3704f0547bc90ac0561418899dd98bdd2148.tar.gz | |
Added test to invoke the queue index walker
| -rw-r--r-- | src/rabbit_tests.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 8e99780d0f..3597efe3a6 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -1833,6 +1833,7 @@ test_variable_queue_partial_segments_delta_thing() -> test_queue_recover() -> Count = 2*rabbit_queue_index:next_segment_boundary(0), + TxID = rabbit_guid:guid(), #amqqueue { pid = QPid, name = QName } = Q = rabbit_amqqueue:declare(test_queue(), true, false, [], none), Msg = fun() -> rabbit_basic:message( @@ -1840,12 +1841,12 @@ test_queue_recover() -> <<>>, #'P_basic'{delivery_mode = 2}, <<>>) end, Delivery = #delivery{mandatory = false, immediate = false, - txn = none, + txn = TxID, sender = self(), message = Msg()}, [true = rabbit_amqqueue:deliver(QPid, Delivery) || _ <- lists:seq(1, Count)], - rabbit_amqqueue:stat(Q), - exit(QPid, shutdown), + rabbit_amqqueue:commit_all([QPid], TxID, self()), + exit(QPid, kill), MRef = erlang:monitor(process, QPid), receive {'DOWN', MRef, process, QPid, _Info} -> ok after 10000 -> exit(timeout_waiting_for_queue_death) |