diff --git a/deps/rabbitmq_sharding/src/rabbit_sharding_util.erl b/deps/rabbitmq_sharding/src/rabbit_sharding_util.erl index e1968617d4..5e98ede326 100644 --- a/deps/rabbitmq_sharding/src/rabbit_sharding_util.erl +++ b/deps/rabbitmq_sharding/src/rabbit_sharding_util.erl @@ -42,18 +42,18 @@ routing_key(X) -> get_policy(X) -> rabbit_policy:get(<<"sharding-definition">>, X). -get_parameter(Parameter, X, Default) -> - Default2 = rabbit_runtime_parameters:value( - vhost(X), <<"sharding">>, Parameter, Default), - get_parameter_value(<<"sharding-definition">>, Parameter, - X, Default2). - exchange_bin(#resource{name = XBin}) -> XBin. a2b(A) -> list_to_binary(atom_to_list(A)). %%---------------------------------------------------------------------------- +get_parameter(Parameter, X, Default) -> + Default2 = rabbit_runtime_parameters:value( + vhost(X), <<"sharding">>, Parameter, Default), + get_parameter_value(<<"sharding-definition">>, Parameter, + X, Default2). + get_parameter_value(Comp, Param, X, Default) -> case get_policy(X) of undefined -> Default;