moves get_parameter to the private function section
This commit is contained in:
parent
44c7769c8d
commit
65250a169a
|
|
@ -42,18 +42,18 @@ routing_key(X) ->
|
||||||
get_policy(X) ->
|
get_policy(X) ->
|
||||||
rabbit_policy:get(<<"sharding-definition">>, 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.
|
exchange_bin(#resource{name = XBin}) -> XBin.
|
||||||
|
|
||||||
a2b(A) -> list_to_binary(atom_to_list(A)).
|
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) ->
|
get_parameter_value(Comp, Param, X, Default) ->
|
||||||
case get_policy(X) of
|
case get_policy(X) of
|
||||||
undefined -> Default;
|
undefined -> Default;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue