Skip to content

Commit 9143dbe

Browse files
ansdlhoguin
authored andcommitted
Do not open WebMQTT connection in MQTT plugin
1 parent ed89b0c commit 9143dbe

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

test/web_mqtt_command_SUITE.erl

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
[connect/3, connect/4]).
1717

1818
-define(COMMAND, 'Elixir.RabbitMQ.CLI.Ctl.Commands.ListWebMqttConnectionsCommand').
19+
-define(MQTT_COMMAND, 'Elixir.RabbitMQ.CLI.Ctl.Commands.ListMqttConnectionsCommand').
1920

2021
all() ->
2122
[
@@ -93,12 +94,16 @@ run(BaseConfig) ->
9394
[] = 'Elixir.Enum':to_list(?COMMAND:run([<<"client_id">>], Opts)),
9495

9596
%% Open a WebMQTT connection
96-
9797
C2 = connect(<<"simpleWebMqttClient">>, Config, [{ack_timeout, 1}]),
9898
timer:sleep(200),
9999

100+
%% WebMQTT CLI should list only WebMQTT connection.
100101
[[{client_id, <<"simpleWebMqttClient">>}]] =
101-
'Elixir.Enum':to_list(?COMMAND:run([<<"client_id">>], Opts)),
102+
'Elixir.Enum':to_list(?COMMAND:run([<<"client_id">>], Opts)),
103+
104+
%% MQTT CLI should list only MQTT connection.
105+
[[{client_id, <<"simpleMqttClient">>}]] =
106+
'Elixir.Enum':to_list(?MQTT_COMMAND:run([<<"client_id">>], Opts)),
102107

103108
C3 = connect(<<"simpleWebMqttClient1">>, Config, [{ack_timeout, 1}]),
104109
timer:sleep(200),

0 commit comments

Comments
 (0)