diff options
Diffstat (limited to 'deps')
| -rw-r--r-- | deps/rabbit_common/src/rabbit_ct_broker_helpers.erl | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl b/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl index a7e09d7fd2..4c575257a7 100644 --- a/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl +++ b/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl @@ -83,7 +83,9 @@ tcp_port_amqp_tls, tcp_port_mgmt, tcp_port_erlang_dist, - tcp_port_erlang_dist_proxy + tcp_port_erlang_dist_proxy, + tcp_port_mqtt, + tcp_port_web_mqtt ]). %% ------------------------------------------------------------------- @@ -268,6 +270,14 @@ update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_mgmt = Key | Rest]) -> NodeConfig1 = rabbit_ct_helpers:merge_app_env(NodeConfig, {rabbitmq_management, [{listener, [{port, ?config(Key, NodeConfig)}]}]}), update_tcp_ports_in_rmq_config(NodeConfig1, Rest); +update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_mqtt = Key | Rest]) -> + NodeConfig1 = rabbit_ct_helpers:merge_app_env(NodeConfig, + {rabbitmq_mqtt, [{tcp_listeners, [?config(Key, NodeConfig)]}]}), + update_tcp_ports_in_rmq_config(NodeConfig1, Rest); +update_tcp_ports_in_rmq_config(NodeConfig, [tcp_port_web_mqtt = Key | Rest]) -> + NodeConfig1 = rabbit_ct_helpers:merge_app_env(NodeConfig, + {rabbitmq_web_mqtt, [{tcp_config, [{port, ?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); |