diff options
| -rw-r--r-- | src/rabbit_policy.erl | 5 | ||||
| -rw-r--r-- | src/rabbit_runtime_parameters.erl | 5 | ||||
| -rw-r--r-- | src/rabbit_vhost_limit.erl | 5 |
3 files changed, 3 insertions, 12 deletions
diff --git a/src/rabbit_policy.erl b/src/rabbit_policy.erl index 2106a12e4d..cfbf116cbd 100644 --- a/src/rabbit_policy.erl +++ b/src/rabbit_policy.erl @@ -212,10 +212,7 @@ parse_set(Type, VHost, Name, Pattern, Definition, Priority, ApplyTo) -> end. parse_set0(Type, VHost, Name, Pattern, Defn, Priority, ApplyTo) -> - Definition = case Defn of - Defn when is_list(Defn) -> list_to_binary(Defn); - Defn -> Defn - end, + Definition = rabbit_data_coercion:to_binary(Defn), case rabbit_json:try_decode(Definition) of {ok, Term} -> set0(Type, VHost, Name, diff --git a/src/rabbit_runtime_parameters.erl b/src/rabbit_runtime_parameters.erl index 6571c4828e..072a48be3d 100644 --- a/src/rabbit_runtime_parameters.erl +++ b/src/rabbit_runtime_parameters.erl @@ -97,10 +97,7 @@ parse_set(_, <<"policy">>, _, _, _) -> {error_string, "policies may not be set using this method"}; parse_set(VHost, Component, Name, String, User) -> - Definition = case String of - String when is_list(String) -> list_to_binary(String); - String -> String - end, + Definition = rabbit_data_coercion:to_binary(String), case rabbit_json:try_decode(Definition) of {ok, Term} when is_map(Term) -> set(VHost, Component, Name, maps:to_list(Term), User); {ok, Term} -> set(VHost, Component, Name, Term, User); diff --git a/src/rabbit_vhost_limit.erl b/src/rabbit_vhost_limit.erl index a54ba9629e..287488b28b 100644 --- a/src/rabbit_vhost_limit.erl +++ b/src/rabbit_vhost_limit.erl @@ -124,10 +124,7 @@ is_over_queue_limit(VirtualHost) -> %%---------------------------------------------------------------------------- parse_set(VHost, Defn) -> - Definition = case Defn of - Defn when is_list(Defn) -> list_to_binary(Defn); - Defn -> Defn - end, + Definition = rabbit_data_coercion:to_binary(Defn), case rabbit_json:try_decode(Definition) of {ok, Term} -> set(VHost, maps:to_list(Term)); |