diff options
| author | Tim Watson <watson.timothy@gmail.com> | 2013-12-19 10:19:44 +0000 |
|---|---|---|
| committer | Tim Watson <watson.timothy@gmail.com> | 2013-12-19 10:19:44 +0000 |
| commit | caee64cd25e429f094b0a7528a335add13bf4d22 (patch) | |
| tree | 3e99d55dbb7558955dbc5d65989ca316bb28d679 /src/rabbit_tests.erl | |
| parent | 9db4fd04f9bbda5a1a3d2b956db68cedffd1fc99 (diff) | |
| download | rabbitmq-server-caee64cd25e429f094b0a7528a335add13bf4d22.tar.gz | |
Rework/Refactor to handle recovery terms up-front
We process all the recovery terms up-front, during qi recovery, and
clear + sync the dets table immediately afterwards. The recovery terms
and keys, based on the queue directory?s ?basename?, are then passed
throughout the initialisation process and checked in the various
places they?re used.
Diffstat (limited to 'src/rabbit_tests.erl')
| -rw-r--r-- | src/rabbit_tests.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 5fe319d3..7aafb23d 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -2129,11 +2129,12 @@ test_queue() -> init_test_queue() -> TestQueue = test_queue(), + %% TODO: shutdown_terms is no longer relevant - rework this test case Terms = rabbit_queue_index:shutdown_terms(TestQueue), PRef = proplists:get_value(persistent_ref, Terms, rabbit_guid:gen()), PersistentClient = msg_store_client_init(?PERSISTENT_MSG_STORE, PRef), Res = rabbit_queue_index:recover( - TestQueue, Terms, false, + TestQueue, {clean_shutdown, Terms}, false, fun (MsgId) -> rabbit_msg_store:contains(MsgId, PersistentClient) end, |