Skip to content

Commit 597858b

Browse files
Merge pull request #10996 from rabbitmq/mergify/bp/v3.13.x/pr-10995
Fix mnesia deletion return value in recent history exchange cleanup (backport #10995)
2 parents f50dea8 + 4115847 commit 597858b

File tree

2 files changed

+18
-2
lines changed

2 files changed

+18
-2
lines changed

deps/rabbitmq_recent_history_exchange/src/rabbit_db_rh_exchange.erl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,12 @@ delete() ->
142142
}).
143143

144144
delete_in_mnesia() ->
145-
mnesia:delete_table(?RH_TABLE).
145+
case mnesia:delete_table(?RH_TABLE) of
146+
{atomic, ok} ->
147+
ok;
148+
{aborted, Reason} ->
149+
{error, Reason}
150+
end.
146151

147152
delete_in_khepri() ->
148153
rabbit_khepri:delete(khepri_recent_history_path()).

deps/rabbitmq_recent_history_exchange/test/system_SUITE.erl

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,8 @@ all_tests() ->
4141
wrong_argument_type_test,
4242
no_store_test,
4343
e2e_test,
44-
multinode_test
44+
multinode_test,
45+
lifecycle_test
4546
].
4647

4748
%% -------------------------------------------------------------------
@@ -235,6 +236,16 @@ multinode_test(Config) ->
235236
rabbit_ct_client_helpers:close_connection_and_channel(Conn2, Chan2),
236237
ok.
237238

239+
lifecycle_test(Config) ->
240+
%% Ensure that the boot and cleanup steps run as expected and return 'ok'.
241+
ok = rabbit_ct_broker_helpers:rpc(
242+
Config,
243+
rabbit, stop_apps, [[rabbitmq_recent_history_exchange]]),
244+
ok = rabbit_ct_broker_helpers:rpc(
245+
Config,
246+
rabbit, start_apps, [[rabbitmq_recent_history_exchange]]),
247+
ok.
248+
238249
test0(Config, MakeMethod, MakeMsg, DeclareArgs, Queues, MsgCount, ExpectedCount) ->
239250
Chan = rabbit_ct_client_helpers:open_channel(Config),
240251
#'exchange.declare_ok'{} =

0 commit comments

Comments
 (0)