Skip test if plugin is not installed

Author: MarcialRosales

deps/rabbitmq_local_exchange/src/rabbit_exchange_type_local.erl

@@ -12,6 +12,7 @@
 -rabbit_boot_step({?MODULE, [
   {description,   "exchange type local"},
   {mfa,           {rabbit_registry, register, [exchange, <<"x-local">>, ?MODULE]}},
+  {cleanup,       {?MODULE, disable_plugin, []}},
   {requires,      rabbit_registry},
   {enables,       kernel_ready}
 ]}).
@@ -30,7 +31,8 @@
   serialise_events/0,
   validate/1,
   info/1,
-  info/2
+  info/2,
+  disable_plugin/0
 ]).
 
 description() ->
@@ -76,3 +78,7 @@ remove_bindings(_Serial, _X, _Bs) -> ok.
 validate_binding(_X, _B) -> ok.
 assert_args_equivalence(X, Args) ->
     rabbit_exchange:assert_args_equivalence(X, Args).
+
+disable_plugin() ->
+    rabbit_registry:unregister(exchange, <<"x-local">>),
+    ok.

deps/rabbitmq_local_exchange/test/rabbit_local_exchange_SUITE.erl

@@ -54,6 +54,11 @@ init_per_testcase(Testcase, Config) ->
     TestCaseName = rabbit_ct_helpers:config_to_testcase_name(Config, Testcase),
     Config1 = rabbit_ct_helpers:set_config(Config, {test_resource_name,
                                                     re:replace(TestCaseName, "/", "-", [global, {return, list}])}),
+    Nodes = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
+    [case rabbit_ct_broker_helpers:enable_plugin(Config, N, rabbitmq_local_exchange) of
+      ok -> ok;
+      _ -> {skip}
+    end || N <- Nodes],
     rabbit_ct_helpers:testcase_started(Config1, Testcase).
 
 end_per_testcase(Testcase, Config) ->
@@ -64,6 +69,8 @@ end_per_testcase(Testcase, Config) ->
 %% -------------------------------------------------------------------
 
 routed_to_one_local_queue_test(Config) ->
+    % ok = ensure_plugin_enabled(Config),
+
     E = make_exchange_name(Config, "0"),
     declare_exchange(Config, E),
     %% declare queue on the first two nodes: 0, 1
@@ -76,6 +83,8 @@ routed_to_one_local_queue_test(Config) ->
     passed.
 
 routed_to_one_nonlocal_queue_test(Config) ->
+    % ok = ensure_plugin_enabled(Config),
+
     E = make_exchange_name(Config, "0"),
     declare_exchange(Config, E),
     %% declare queue on nodes 0, 1