115 lines
6.5 KiB
Erlang
115 lines
6.5 KiB
Erlang
|
%% This Source Code Form is subject to the terms of the Mozilla Public
|
||
|
|
%% License, v. 2.0. If a copy of the MPL was not distributed with this
|
||
|
|
%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
|
||
|
|
%%
|
||
|
|
%% Copyright (c) 2007-2025 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries. All rights reserved.
|
||
|
|
|
||
|
|
%% This test suite uses test cases shared by rabbitmq_mqtt.
|
||
|
|
-module(web_mqtt_v5_SUITE).
|
||
|
|
-compile([export_all,
|
||
|
|
nowarn_export_all]).
|
||
|
|
|
||
|
|
all() ->
|
||
|
|
v5_SUITE:all().
|
||
|
|
|
||
|
|
groups() ->
|
||
|
|
v5_SUITE:groups().
|
||
|
|
|
||
|
|
suite() ->
|
||
|
|
v5_SUITE:suite().
|
||
|
|
|
||
|
|
init_per_suite(Config) ->
|
||
|
|
v5_SUITE:init_per_suite(Config).
|
||
|
|
|
||
|
|
end_per_suite(Config) ->
|
||
|
|
v5_SUITE:end_per_suite(Config).
|
||
|
|
|
||
|
|
init_per_group(mqtt, Config) ->
|
||
|
|
%% This is the main difference with rabbitmq_mqtt.
|
||
|
|
rabbit_ct_helpers:set_config(Config, {websocket, true});
|
||
|
|
init_per_group(Group, Config) ->
|
||
|
|
v5_SUITE:init_per_group(Group, Config).
|
||
|
|
|
||
|
|
end_per_group(Group, Config) ->
|
||
|
|
v5_SUITE:end_per_group(Group, Config).
|
||
|
|
|
||
|
|
init_per_testcase(Testcase, Config) ->
|
||
|
|
v5_SUITE:init_per_testcase(Testcase, Config).
|
||
|
|
|
||
|
|
end_per_testcase(Testcase, Config) ->
|
||
|
|
v5_SUITE:end_per_testcase(Testcase, Config).
|
||
|
|
|
||
|
|
client_set_max_packet_size_publish(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_set_max_packet_size_connack(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_set_max_packet_size_invalid(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
message_expiry(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
message_expiry_will_message(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
message_expiry_retained_message(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_classic_queue_disconnect_decrease(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_quorum_queue_disconnect_decrease(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_disconnect_zero_to_non_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_disconnect_non_zero_to_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_disconnect_infinity_to_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_disconnect_to_infinity(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_reconnect_non_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_reconnect_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_expiry_reconnect_infinity_to_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_publish_qos2(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_rejects_publish(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_receive_maximum_min(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
client_receive_maximum_large(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
unsubscribe_success(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
unsubscribe_topic_not_found(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_option_no_local(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_option_no_local_wildcards(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_option_retain_as_published(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_option_retain_as_published_wildcards(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_option_retain_handling(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_identifier(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_identifier_amqp091(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_identifier_at_most_once_dead_letter(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
at_most_once_dead_letter_detect_cycle(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_options_persisted(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_options_modify(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_options_modify_qos1(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
subscription_options_modify_qos0(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_upgrade_v3_v5_qos1(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_upgrade_v3_v5_qos0(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_upgrade_v3_v5_amqp091_pub(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
compatibility_v3_v5(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_upgrade_v3_v5_unsubscribe(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_upgrade_v4_v5_no_queue_bind_permission(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
amqp091_cc_header(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
publish_property_content_type(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
publish_property_payload_format_indicator(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
publish_property_response_topic_correlation_data(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
publish_property_user_property(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
disconnect_with_will(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_qos2(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_greater_than_session_expiry(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_less_than_session_expiry(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_equals_session_expiry(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_session_expiry_zero(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_reconnect_no_will(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_reconnect_with_will(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_session_takeover(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_message_expiry(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_message_expiry_publish_properties(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_properties(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_properties(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
retain_properties(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_client_to_server(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_server_to_client(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_bidirectional(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_invalid(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_unknown(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_disallowed(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_retained_message(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
topic_alias_disallowed_retained_message(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
extended_auth(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
headers_exchange(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
consistent_hash_exchange(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_migrate_v3_v5(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
session_takeover_v3_v5(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|
||
|
|
will_delay_node_restart(Config) -> v5_SUITE:?FUNCTION_NAME(Config).
|