diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-15 16:40:36 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-07-15 16:40:36 +0100 |
| commit | 3ea08a9ad561e88b3d1996835226db8a1619e61e (patch) | |
| tree | 9988bf0bdbba86b1a0110fdd706b6c1c41b63dac | |
| parent | 1415c54ab973255fd547cbccfb805cb75ddab6a7 (diff) | |
| download | rabbitmq-server-git-3ea08a9ad561e88b3d1996835226db8a1619e61e.tar.gz | |
cleanup queue and restart app
| -rw-r--r-- | src/rabbit_tests.erl | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 63676fef64..2542905f0c 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -60,6 +60,9 @@ all_tests() -> passed = test_confirms(), passed = maybe_run_cluster_dependent_tests(), passed = test_configurable_server_properties(), + ok = cleanup_test_queue(), + ok = restart_app(), + io:format("rabbit app restarted"), passed. maybe_run_cluster_dependent_tests() -> @@ -1911,6 +1914,16 @@ with_empty_test_queue(Fun) -> {0, Qi} = init_test_queue(), rabbit_queue_index:delete_and_terminate(Fun(Qi)). +cleanup_test_queue() -> + %% the test queue's already there; let's remove it + {_, Q} = rabbit_amqqueue:declare(test_queue(), true, false, [], none), + {ok, _} = rabbit_amqqueue:delete(Q, false, false), + ok. + +restart_app() -> + rabbit:stop(), + rabbit:start(). + queue_index_publish(SeqIds, Persistent, Qi) -> Ref = rabbit_guid:guid(), MsgStore = case Persistent of |