summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_direct.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_direct.erl b/src/rabbit_direct.erl
index b918d2e671..b84b4d91bb 100644
--- a/src/rabbit_direct.erl
+++ b/src/rabbit_direct.erl
@@ -132,7 +132,9 @@ extract_protocol(Infos) ->
maybe_call_connection_info_module(Protocol, Creds, VHost, Pid, Infos) ->
Module = rabbit_data_coercion:to_atom(string:to_lower(
- "rabbit_" ++ rabbit_data_coercion:to_list(Protocol) ++ "_connection_info")
+ "rabbit_" ++
+ lists:flatten(string:replace(rabbit_data_coercion:to_list(Protocol), " ", "_", all)) ++
+ "_connection_info")
),
Args = [Creds, VHost, Pid, Infos],
code_server_cache:maybe_call_mfa(Module, additional_authn_params, Args, []).