Add stream TCP port to start broker

This commit is contained in:
Arnaud Cogoluègnes 2020-03-16 16:52:13 +01:00 committed by kjnilsson
parent 25cb487b5e
commit 34e5781eb9
1 changed files with 6 additions and 1 deletions

View File

@ -183,7 +183,8 @@
tcp_port_stomp,
tcp_port_stomp_tls,
tcp_port_web_stomp,
tcp_port_web_stomp_tls
tcp_port_web_stomp_tls,
tcp_port_stream
]).
%% -------------------------------------------------------------------
@ -508,6 +509,10 @@ update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_stomp_tls = Key | Rest]) ->
NodeConfig1 = rabbit_ct_helpers:merge_app_env(NodeConfig,
{rabbitmq_stomp, [{ssl_listeners, [?config(Key, NodeConfig)]}]}),
update_tcp_ports_in_rmq_config(NodeConfig1, Rest);
update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_stream = Key | Rest]) ->
NodeConfig1 = rabbit_ct_helpers:merge_app_env(NodeConfig,
{rabbitmq_stream, [{tcp_listeners, [?config(Key, NodeConfig)]}]}),
update_tcp_ports_in_rmq_config(NodeConfig1, Rest);
update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_erlang_dist | Rest]) ->
%% The Erlang distribution port doesn't appear in the configuration file.
update_tcp_ports_in_rmq_config(NodeConfig, Rest);