@@ -254,7 +254,7 @@ prepare_plugins(Enabled) ->
254
254
Wanted = dependencies (false , Enabled , AllPlugins ),
255
255
WantedPlugins = lookup_plugins (Wanted , AllPlugins ),
256
256
{ValidPlugins , Problems } = validate_plugins (WantedPlugins ),
257
- % TODO: error message formatting
257
+ % % TODO: error message formatting
258
258
rabbit_log :warning (format_invalid_plugins (Problems )),
259
259
case filelib :ensure_dir (ExpandDir ++ " /" ) of
260
260
ok -> ok ;
@@ -279,11 +279,11 @@ format_invalid_plugin({Name, Errors}) ->
279
279
format_invalid_plugin_error ({missing_dependency , Dep }) ->
280
280
io_lib :format (" Dependency is missing or invalid: ~p~n " , [Dep ]);
281
281
format_invalid_plugin_error ({broker_version_mismatch , Version , Required }) ->
282
- io_lib :format (" Broker version is invalid ."
283
- " Current version: ~p Required : ~p~n " , [Version , Required ]);
282
+ io_lib :format (" Plugin doesn't support current server version ."
283
+ " Actual broker version: ~p , supported by the plugin : ~p~n " , [Version , Required ]);
284
284
format_invalid_plugin_error ({{version_mismatch , Version , Required }, Name }) ->
285
- io_lib :format (" ~p plugin version is invalid ."
286
- " Current version: ~p Required : ~p~n " ,
285
+ io_lib :format (" ~p plugin version is unsupported ."
286
+ " Actual version: ~p , supported : ~p~n " ,
287
287
[Name , Version , Required ]);
288
288
format_invalid_plugin_error (Err ) ->
289
289
io_lib :format (" Unknown error ~p~n " , [Err ]).
@@ -296,20 +296,20 @@ validate_plugins(Plugins) ->
296
296
end ,
297
297
validate_plugins (Plugins , RabbitVersion ).
298
298
299
- validate_plugins (Plugins , RabbitVersion ) ->
299
+ validate_plugins (Plugins , BrokerVersion ) ->
300
300
lists :foldl (
301
301
fun (# plugin {name = Name ,
302
- broker_version_requirements = RabbitmqVersions ,
302
+ broker_version_requirements = BrokerVersionReqs ,
303
303
dependency_version_requirements = DepsVersions } = Plugin ,
304
304
{Plugins0 , Errors }) ->
305
- case is_version_supported (RabbitVersion , RabbitmqVersions ) of
305
+ case is_version_supported (BrokerVersion , BrokerVersionReqs ) of
306
306
true ->
307
307
case check_plugins_versions (Plugins0 , DepsVersions ) of
308
308
ok -> {[Plugin | Plugins0 ], Errors };
309
309
{error , Err } -> {Plugins0 , [{Name , Err } | Errors ]}
310
310
end ;
311
311
false ->
312
- Error = [{broker_version_mismatch , RabbitVersion , RabbitmqVersions }],
312
+ Error = [{broker_version_mismatch , BrokerVersion , BrokerVersionReqs }],
313
313
{Plugins0 , [{Name , Error } | Errors ]}
314
314
end
315
315
end ,
0 commit comments