diff --git a/.github/workflows/ibm-mq-make.yaml b/.github/workflows/ibm-mq-make.yaml index f23d8a437a2..0cfab3520c9 100644 --- a/.github/workflows/ibm-mq-make.yaml +++ b/.github/workflows/ibm-mq-make.yaml @@ -6,9 +6,9 @@ on: - 'main' paths: - '.github/workflows/ibm-mq-make.yaml' - pull_request: - paths: - - '.github/workflows/ibm-mq-make.yaml' + # pull_request: + # paths: + # - '.github/workflows/ibm-mq-make.yaml' env: REGISTRY_IMAGE: pivotalrabbitmq/ibm-mqadvanced-server-dev @@ -64,4 +64,4 @@ jobs: password: ${{ secrets.DOCKERHUB_PASSWORD }} - name: Push run: | - docker push ${{ env.REGISTRY_IMAGE }}:${{ env.IMAGE_TAG }} \ No newline at end of file + docker push ${{ env.REGISTRY_IMAGE }}:${{ env.IMAGE_TAG }} diff --git a/.github/workflows/oci-make.yaml b/.github/workflows/oci-make.yaml index 98353c8aa27..3ff2b8e0b90 100644 --- a/.github/workflows/oci-make.yaml +++ b/.github/workflows/oci-make.yaml @@ -7,13 +7,13 @@ name: OCI (make) on: pull_request: paths: - - deps/** + # - deps/** - scripts/** - - Makefile + # - Makefile - plugins.mk - rabbitmq-components.mk - packaging/** - - .github/workflows/oci-make.yaml + # - .github/workflows/oci-make.yaml workflow_dispatch: inputs: otp_version: diff --git a/.github/workflows/test-authnz.yaml b/.github/workflows/test-authnz.yaml index 6b1ec4f02c1..7a781782dcc 100644 --- a/.github/workflows/test-authnz.yaml +++ b/.github/workflows/test-authnz.yaml @@ -13,13 +13,13 @@ on: - 'deps/rabbitmq_management/selenium/**' - 'scripts/**' - .github/workflows/test-authnz.yaml - pull_request: - paths: - - 'selenium/**' - - 'deps/rabbit/**' - - 'deps/rabbitmq_auth_/**' - - 'deps/rabbitmq_mqtt/**' - - .github/workflows/test-authnz.yaml + # pull_request: + # paths: + # - 'selenium/**' + # - 'deps/rabbit/**' + # - 'deps/rabbitmq_auth_/**' + # - 'deps/rabbitmq_mqtt/**' + # - .github/workflows/test-authnz.yaml concurrency: group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }} cancel-in-progress: true diff --git a/.github/workflows/test-make-target.yaml b/.github/workflows/test-make-target.yaml index 15843138c94..e4c716e6365 100644 --- a/.github/workflows/test-make-target.yaml +++ b/.github/workflows/test-make-target.yaml @@ -37,6 +37,7 @@ jobs: uses: erlef/setup-beam@v1.17 with: otp-version: ${{ inputs.erlang_version }} + # version-type: strict elixir-version: ${{ inputs.elixir_version }} hexpm-mirrors: | https://builds.hex.pm diff --git a/.github/workflows/test-make-tests.yaml b/.github/workflows/test-make-tests.yaml index cdffd87189d..a18b00ecee3 100644 --- a/.github/workflows/test-make-tests.yaml +++ b/.github/workflows/test-make-tests.yaml @@ -21,17 +21,17 @@ jobs: fail-fast: false matrix: make_target: - - parallel-ct-set-1 - - parallel-ct-set-2 - - parallel-ct-set-3 - - parallel-ct-set-4 + # - parallel-ct-set-1 + # - parallel-ct-set-2 + # - parallel-ct-set-3 + # - parallel-ct-set-4 - ct-amqp_client - - ct-clustering_management - - eunit ct-dead_lettering - - ct-feature_flags - - ct-metadata_store_clustering - - ct-quorum_queue - - ct-rabbit_stream_queue + # - ct-clustering_management + # - eunit ct-dead_lettering + # - ct-feature_flags + # - ct-metadata_store_clustering + # - ct-quorum_queue + # - ct-rabbit_stream_queue uses: ./.github/workflows/test-make-target.yaml with: erlang_version: ${{ inputs.erlang_version }} @@ -41,84 +41,82 @@ jobs: make_target: ${{ matrix.make_target }} plugin: rabbit - test-rabbitmq-mqtt: - name: Test rabbitmq_mqtt - uses: ./.github/workflows/test-make-target.yaml - with: - erlang_version: ${{ inputs.erlang_version }} - elixir_version: ${{ inputs.elixir_version }} - metadata_store: ${{ inputs.metadata_store }} - mixed_clusters: ${{ inputs.mixed_clusters }} - make_target: parallel-ct-set-1 - plugin: rabbitmq_mqtt + # test-rabbitmq-mqtt: + # name: Test rabbitmq_mqtt + # uses: ./.github/workflows/test-make-target.yaml + # with: + # erlang_version: ${{ inputs.erlang_version }} + # elixir_version: ${{ inputs.elixir_version }} + # metadata_store: ${{ inputs.metadata_store }} + # mixed_clusters: ${{ inputs.mixed_clusters }} + # make_target: parallel-ct-set-1 + # plugin: rabbitmq_mqtt - # The integration_SUITE requires secrets and - # is therefore run from a separate workflow. - test-rabbitmq-peer-discovery-aws: - name: Test rabbitmq_peer_discovery_aws (partially) - uses: ./.github/workflows/test-make-target.yaml - with: - erlang_version: ${{ inputs.erlang_version }} - elixir_version: ${{ inputs.elixir_version }} - metadata_store: ${{ inputs.metadata_store }} - mixed_clusters: ${{ inputs.mixed_clusters }} - make_target: ct-config_schema ct-unit - plugin: rabbitmq_peer_discovery_aws + # # The integration_SUITE requires secrets and + # # is therefore run from a separate workflow. + # test-rabbitmq-peer-discovery-aws: + # name: Test rabbitmq_peer_discovery_aws (partially) + # uses: ./.github/workflows/test-make-target.yaml + # with: + # erlang_version: ${{ inputs.erlang_version }} + # elixir_version: ${{ inputs.elixir_version }} + # metadata_store: ${{ inputs.metadata_store }} + # mixed_clusters: ${{ inputs.mixed_clusters }} + # make_target: ct-config_schema ct-unit + # plugin: rabbitmq_peer_discovery_aws - test-plugin: - name: Test plugins - strategy: - fail-fast: false - matrix: - plugin: - - amqp10_client - - amqp10_common - - amqp_client - - oauth2_client - - rabbit_common - - rabbitmq_amqp_client - - rabbitmq_auth_backend_cache - - rabbitmq_auth_backend_http - - rabbitmq_auth_backend_ldap - - rabbitmq_auth_backend_oauth2 - - rabbitmq_auth_mechanism_ssl - - rabbitmq_aws - - rabbitmq_cli - - rabbitmq_consistent_hash_exchange - - rabbitmq_event_exchange - - rabbitmq_exchange_federation - - rabbitmq_federation_common - - rabbitmq_federation_management - - rabbitmq_federation_prometheus - - rabbitmq_jms_topic_exchange - - rabbitmq_management - - rabbitmq_management_agent - - rabbitmq_peer_discovery_common - - rabbitmq_peer_discovery_consul - - rabbitmq_peer_discovery_etcd - - rabbitmq_peer_discovery_k8s - - rabbitmq_prelaunch - - rabbitmq_prometheus - - rabbitmq_queue_federation - - rabbitmq_recent_history_exchange - - rabbitmq_sharding - - rabbitmq_shovel - - rabbitmq_shovel_management - - rabbitmq_shovel_prometheus - - rabbitmq_stomp - - rabbitmq_stream - - rabbitmq_stream_common - - rabbitmq_stream_management - - rabbitmq_tracing - - rabbitmq_trust_store - - rabbitmq_web_dispatch - - rabbitmq_web_mqtt - - rabbitmq_web_stomp - uses: ./.github/workflows/test-make-target.yaml - with: - erlang_version: ${{ inputs.erlang_version }} - elixir_version: ${{ inputs.elixir_version }} - metadata_store: ${{ inputs.metadata_store }} - mixed_clusters: ${{ inputs.mixed_clusters }} - make_target: tests - plugin: ${{ matrix.plugin }} + # test-plugin: + # name: Test plugins + # strategy: + # fail-fast: false + # matrix: + # plugin: + # - amqp10_client + # - amqp10_common + # - amqp_client + # - oauth2_client + # - rabbit_common + # - rabbitmq_amqp_client + # - rabbitmq_auth_backend_cache + # - rabbitmq_auth_backend_http + # - rabbitmq_auth_backend_ldap + # - rabbitmq_auth_backend_oauth2 + # - rabbitmq_auth_mechanism_ssl + # - rabbitmq_aws + # - rabbitmq_cli + # - rabbitmq_consistent_hash_exchange + # - rabbitmq_event_exchange + # - rabbitmq_federation + # - rabbitmq_federation_management + # - rabbitmq_federation_prometheus + # - rabbitmq_jms_topic_exchange + # - rabbitmq_management + # - rabbitmq_management_agent + # - rabbitmq_peer_discovery_common + # - rabbitmq_peer_discovery_consul + # - rabbitmq_peer_discovery_etcd + # - rabbitmq_peer_discovery_k8s + # - rabbitmq_prelaunch + # - rabbitmq_prometheus + # - rabbitmq_recent_history_exchange + # - rabbitmq_sharding + # - rabbitmq_shovel + # - rabbitmq_shovel_management + # - rabbitmq_shovel_prometheus + # - rabbitmq_stomp + # - rabbitmq_stream + # - rabbitmq_stream_common + # - rabbitmq_stream_management + # - rabbitmq_tracing + # - rabbitmq_trust_store + # - rabbitmq_web_dispatch + # - rabbitmq_web_mqtt + # - rabbitmq_web_stomp + # uses: ./.github/workflows/test-make-target.yaml + # with: + # erlang_version: ${{ inputs.erlang_version }} + # elixir_version: ${{ inputs.elixir_version }} + # metadata_store: ${{ inputs.metadata_store }} + # mixed_clusters: ${{ inputs.mixed_clusters }} + # make_target: tests + # plugin: ${{ matrix.plugin }} \ No newline at end of file diff --git a/.github/workflows/test-make.yaml b/.github/workflows/test-make.yaml index eddf299b536..1e95f7b4b3c 100644 --- a/.github/workflows/test-make.yaml +++ b/.github/workflows/test-make.yaml @@ -15,46 +15,46 @@ concurrency: group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }} cancel-in-progress: true jobs: - build-and-xref: - name: Build and Xref - strategy: - fail-fast: false - matrix: - erlang_version: - - '26' - - '27' - elixir_version: - - '1.17' - # @todo Add macOS and Windows. - runs-on: ubuntu-latest - timeout-minutes: 60 - steps: - - name: CHECKOUT REPOSITORY - uses: actions/checkout@v4 + # build-and-xref: + # name: Build and Xref + # strategy: + # fail-fast: false + # matrix: + # erlang_version: + # - '26' + # - '27' + # elixir_version: + # - '1.17' + # # @todo Add macOS and Windows. + # runs-on: ubuntu-latest + # timeout-minutes: 60 + # steps: + # - name: CHECKOUT REPOSITORY + # uses: actions/checkout@v4 - - name: FETCH TAGS - run: git fetch --tags + # - name: FETCH TAGS + # run: git fetch --tags - - name: SETUP OTP & ELIXIR - uses: erlef/setup-beam@v1.17 - with: - otp-version: ${{ matrix.erlang_version }} - elixir-version: ${{ matrix.elixir_version }} - hexpm-mirrors: | - https://builds.hex.pm - https://cdn.jsdelivr.net/hex + # - name: SETUP OTP & ELIXIR + # uses: erlef/setup-beam@v1.17 + # with: + # otp-version: ${{ matrix.erlang_version }} + # elixir-version: ${{ matrix.elixir_version }} + # hexpm-mirrors: | + # https://builds.hex.pm + # https://cdn.jsdelivr.net/hex - - name: SANITY CHECK (rabbit) - run: make -C deps/rabbit parallel-ct-sanity-check + # - name: SANITY CHECK (rabbit) + # run: make -C deps/rabbit parallel-ct-sanity-check - - name: SANITY CHECK (rabbitmq_mqtt) - run: make -C deps/rabbitmq_mqtt parallel-ct-sanity-check + # - name: SANITY CHECK (rabbitmq_mqtt) + # run: make -C deps/rabbitmq_mqtt parallel-ct-sanity-check - - name: BUILD - run: make + # - name: BUILD + # run: make - - name: XREF - run: make xref + # - name: XREF + # run: make xref test: name: Test @@ -67,7 +67,7 @@ jobs: - '1.17' metadata_store: - mnesia - - khepri + # - khepri uses: ./.github/workflows/test-make-tests.yaml with: erlang_version: ${{ matrix.erlang_version }} @@ -75,35 +75,35 @@ jobs: metadata_store: ${{ matrix.metadata_store }} mixed_clusters: false - test-mixed-clusters: - name: Test mixed clusters - strategy: - fail-fast: false - matrix: - erlang_version: - - '27' - elixir_version: - - '1.17' - metadata_store: - - mnesia - - khepri - uses: ./.github/workflows/test-make-tests.yaml - with: - erlang_version: ${{ matrix.erlang_version }} - elixir_version: ${{ matrix.elixir_version }} - metadata_store: ${{ matrix.metadata_store }} - mixed_clusters: true + # test-mixed-clusters: + # name: Test mixed clusters + # strategy: + # fail-fast: false + # matrix: + # erlang_version: + # - '27' + # elixir_version: + # - '1.17' + # metadata_store: + # - mnesia + # - khepri + # uses: ./.github/workflows/test-make-tests.yaml + # with: + # erlang_version: ${{ matrix.erlang_version }} + # elixir_version: ${{ matrix.elixir_version }} + # metadata_store: ${{ matrix.metadata_store }} + # mixed_clusters: true - type-check: - name: Type check - strategy: - fail-fast: false - matrix: - erlang_version: # Latest OTP - - '27' - elixir_version: # Latest Elixir - - '1.17' - uses: ./.github/workflows/test-make-type-check.yaml - with: - erlang_version: ${{ matrix.erlang_version }} - elixir_version: ${{ matrix.elixir_version }} + # type-check: + # name: Type check + # strategy: + # fail-fast: false + # matrix: + # erlang_version: # Latest OTP + # - '27' + # elixir_version: # Latest Elixir + # - '1.17' + # uses: ./.github/workflows/test-make-type-check.yaml + # with: + # erlang_version: ${{ matrix.erlang_version }} + # elixir_version: ${{ matrix.elixir_version }} diff --git a/.github/workflows/test-management-ui-for-pr.yaml b/.github/workflows/test-management-ui-for-pr.yaml index e5fb4ecb06a..bcf043b029a 100644 --- a/.github/workflows/test-management-ui-for-pr.yaml +++ b/.github/workflows/test-management-ui-for-pr.yaml @@ -2,9 +2,9 @@ name: Test Management UI with Selenium for PRs on: pull_request: paths: - - 'deps/**' + # - 'deps/**' - 'selenium/**' - - .github/workflows/test-management-ui-for-pr.yaml + # - .github/workflows/test-management-ui-for-pr.yaml concurrency: group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref }} cancel-in-progress: true diff --git a/deps/rabbit/test/amqp_client_SUITE.erl b/deps/rabbit/test/amqp_client_SUITE.erl index 6c9e26bd399..5d59e87788f 100644 --- a/deps/rabbit/test/amqp_client_SUITE.erl +++ b/deps/rabbit/test/amqp_client_SUITE.erl @@ -44,174 +44,174 @@ all() -> [ - {group, cluster_size_1}, - {group, cluster_size_3}, - {group, metrics} + {group, cluster_size_1} + % {group, cluster_size_3}, + % {group, metrics} ]. groups() -> [ - {cluster_size_1, [shuffle], + {cluster_size_1, [{repeat_until_any_fail, 5}], [ - reliable_send_receive_with_outcomes_classic_queue, - reliable_send_receive_with_outcomes_quorum_queue, - sender_settle_mode_unsettled, - sender_settle_mode_unsettled_fanout, - sender_settle_mode_mixed, - durable_field_classic_queue, - durable_field_quorum_queue, - durable_field_stream, - invalid_transfer_settled_flag, - quorum_queue_rejects, - receiver_settle_mode_first, - publishing_to_non_existing_queue_should_settle_with_released, - open_link_to_non_existing_destination_should_end_session, - roundtrip_with_drain_classic_queue, - roundtrip_with_drain_quorum_queue, - roundtrip_with_drain_stream, - drain_many_classic_queue, - drain_many_quorum_queue, - drain_many_stream, - amqp_stream_amqpl, - amqp_quorum_queue_amqpl, - message_headers_conversion, - multiple_sessions, - server_closes_link_classic_queue, - server_closes_link_quorum_queue, - server_closes_link_stream, - server_closes_link_exchange_settled, - server_closes_link_exchange_unsettled, - link_target_classic_queue_deleted, - link_target_quorum_queue_deleted, - target_queues_deleted_accepted, - events, - sync_get_unsettled_classic_queue, - sync_get_unsettled_quorum_queue, - sync_get_unsettled_stream, - sync_get_unsettled_2_classic_queue, - sync_get_unsettled_2_quorum_queue, - sync_get_unsettled_2_stream, - sync_get_settled_classic_queue, - sync_get_settled_quorum_queue, - sync_get_settled_stream, - timed_get_classic_queue, - timed_get_quorum_queue, - timed_get_stream, - stop_classic_queue, - stop_quorum_queue, - stop_stream, - priority_classic_queue, - priority_quorum_queue, - consumer_priority_classic_queue, - consumer_priority_quorum_queue, - single_active_consumer_classic_queue, - single_active_consumer_quorum_queue, - single_active_consumer_priority_quorum_queue, - single_active_consumer_drain_classic_queue, - single_active_consumer_drain_quorum_queue, - detach_requeues_one_session_classic_queue, - detach_requeues_one_session_quorum_queue, - detach_requeues_drop_head_classic_queue, - resource_alarm_before_session_begin, - resource_alarm_after_session_begin, - resource_alarm_send_many, - max_message_size_client_to_server, - max_message_size_server_to_client, - global_counters, - stream_bloom_filter, - available_messages_classic_queue, - available_messages_quorum_queue, - available_messages_stream, - message_interceptors, - trace_classic_queue, - trace_stream, - user_id, - message_ttl, - plugin, - idle_time_out_on_server, - idle_time_out_on_client, - idle_time_out_too_short, - handshake_timeout, - credential_expires, - attach_to_exclusive_queue, - dynamic_target_short_link_name, - dynamic_target_long_link_name, - dynamic_source_rpc, - dynamic_terminus_delete, - modified_classic_queue, - modified_quorum_queue, - modified_dead_letter_headers_exchange, - modified_dead_letter_history, - dead_letter_headers_exchange, - dead_letter_reject, - dead_letter_reject_message_order_classic_queue, - dead_letter_reject_message_order_quorum_queue, - dead_letter_reject_many_message_order_classic_queue, - dead_letter_reject_many_message_order_quorum_queue, - accept_multiple_message_order_classic_queue, - accept_multiple_message_order_quorum_queue, - release_multiple_message_order_classic_queue, - release_multiple_message_order_quorum_queue, - immutable_bare_message, - receive_many_made_available_over_time_classic_queue, - receive_many_made_available_over_time_quorum_queue, - receive_many_made_available_over_time_stream, - receive_many_auto_flow_classic_queue, - receive_many_auto_flow_quorum_queue, - receive_many_auto_flow_stream, - incoming_window_closed_transfer_flow_order, - incoming_window_closed_stop_link, - incoming_window_closed_close_link, - incoming_window_closed_rabbitmq_internal_flow_classic_queue, - incoming_window_closed_rabbitmq_internal_flow_quorum_queue, - tcp_back_pressure_rabbitmq_internal_flow_classic_queue, - tcp_back_pressure_rabbitmq_internal_flow_quorum_queue, - session_flow_control_default_max_frame_size, - session_flow_control_small_max_frame_size, - session_max_per_connection, - link_max_per_session, - reserved_annotation, - x_cc_annotation_exchange, - x_cc_annotation_exchange_routing_key_empty, - x_cc_annotation_queue, - x_cc_annotation_null, - bad_x_cc_annotation_exchange - ]}, - - {cluster_size_3, [shuffle], - [ - dead_letter_into_stream, - last_queue_confirms, - target_queue_deleted, - target_classic_queue_down, - async_notify_settled_classic_queue, - async_notify_settled_quorum_queue, - async_notify_settled_stream, - async_notify_unsettled_classic_queue, - async_notify_unsettled_quorum_queue, - async_notify_unsettled_stream, - link_flow_control, - classic_queue_on_old_node, - classic_queue_on_new_node, - quorum_queue_on_old_node, - quorum_queue_on_new_node, - maintenance, - leader_transfer_quorum_queue_credit_single, - leader_transfer_quorum_queue_credit_batches, - leader_transfer_stream_credit_single, - leader_transfer_stream_credit_batches, - leader_transfer_quorum_queue_send, - leader_transfer_stream_send, - list_connections, - detach_requeues_two_connections_classic_queue, - detach_requeues_two_connections_quorum_queue, - attach_to_down_quorum_queue - ]}, - - {metrics, [shuffle], - [ - auth_attempt_metrics + % reliable_send_receive_with_outcomes_classic_queue, + % reliable_send_receive_with_outcomes_quorum_queue, + % sender_settle_mode_unsettled, + % sender_settle_mode_unsettled_fanout, + % sender_settle_mode_mixed, + % durable_field_classic_queue, + % durable_field_quorum_queue, + % durable_field_stream, + % invalid_transfer_settled_flag, + % quorum_queue_rejects, + % receiver_settle_mode_first, + % publishing_to_non_existing_queue_should_settle_with_released, + % open_link_to_non_existing_destination_should_end_session, + % roundtrip_with_drain_classic_queue, + % roundtrip_with_drain_quorum_queue, + % roundtrip_with_drain_stream, + % drain_many_classic_queue, + % drain_many_quorum_queue, + % drain_many_stream, + % amqp_stream_amqpl, + % amqp_quorum_queue_amqpl, + % message_headers_conversion, + % multiple_sessions, + % server_closes_link_classic_queue, + % server_closes_link_quorum_queue, + % server_closes_link_stream, + % server_closes_link_exchange_settled, + % server_closes_link_exchange_unsettled, + % link_target_classic_queue_deleted, + % link_target_quorum_queue_deleted, + % target_queues_deleted_accepted, + % events, + % sync_get_unsettled_classic_queue, + % sync_get_unsettled_quorum_queue, + % sync_get_unsettled_stream, + % sync_get_unsettled_2_classic_queue, + % sync_get_unsettled_2_quorum_queue, + % sync_get_unsettled_2_stream, + % sync_get_settled_classic_queue, + % sync_get_settled_quorum_queue, + % sync_get_settled_stream, + % timed_get_classic_queue, + % timed_get_quorum_queue, + % timed_get_stream, + % stop_classic_queue, + % stop_quorum_queue, + % stop_stream, + % priority_classic_queue, + % priority_quorum_queue, + % consumer_priority_classic_queue, + % consumer_priority_quorum_queue, + % single_active_consumer_classic_queue, + % single_active_consumer_quorum_queue, + % single_active_consumer_priority_quorum_queue, + % single_active_consumer_drain_classic_queue, + % single_active_consumer_drain_quorum_queue, + % detach_requeues_one_session_classic_queue, + % detach_requeues_one_session_quorum_queue, + % detach_requeues_drop_head_classic_queue, + % resource_alarm_before_session_begin, + % resource_alarm_after_session_begin, + % resource_alarm_send_many, + % max_message_size_client_to_server, + % max_message_size_server_to_client, + % global_counters, + % stream_bloom_filter, + % available_messages_classic_queue, + % available_messages_quorum_queue, + % available_messages_stream, + % message_interceptors, + % trace_classic_queue, + % trace_stream, + % user_id, + % message_ttl, + % plugin, + % idle_time_out_on_server, + % idle_time_out_on_client, + % idle_time_out_too_short, + % handshake_timeout, + % credential_expires, + % attach_to_exclusive_queue, + % dynamic_target_short_link_name, + % dynamic_target_long_link_name, + % dynamic_source_rpc, + % dynamic_terminus_delete, + % modified_classic_queue, + % modified_quorum_queue, + % modified_dead_letter_headers_exchange, + % modified_dead_letter_history, + % dead_letter_headers_exchange, + % dead_letter_reject, + % dead_letter_reject_message_order_classic_queue, + % dead_letter_reject_message_order_quorum_queue, + % dead_letter_reject_many_message_order_classic_queue, + % dead_letter_reject_many_message_order_quorum_queue, + % accept_multiple_message_order_classic_queue, + % accept_multiple_message_order_quorum_queue, + % release_multiple_message_order_classic_queue, + % release_multiple_message_order_quorum_queue, + % immutable_bare_message, + % receive_many_made_available_over_time_classic_queue, + % receive_many_made_available_over_time_quorum_queue, + % receive_many_made_available_over_time_stream, + % receive_many_auto_flow_classic_queue, + % receive_many_auto_flow_quorum_queue, + % receive_many_auto_flow_stream, + % incoming_window_closed_transfer_flow_order, + % incoming_window_closed_stop_link, + % incoming_window_closed_close_link, + % incoming_window_closed_rabbitmq_internal_flow_classic_queue, + % incoming_window_closed_rabbitmq_internal_flow_quorum_queue, + % tcp_back_pressure_rabbitmq_internal_flow_classic_queue, + tcp_back_pressure_rabbitmq_internal_flow_quorum_queue + % session_flow_control_default_max_frame_size, + % session_flow_control_small_max_frame_size, + % session_max_per_connection, + % link_max_per_session, + % reserved_annotation, + % x_cc_annotation_exchange, + % x_cc_annotation_exchange_routing_key_empty, + % x_cc_annotation_queue, + % x_cc_annotation_null, + % bad_x_cc_annotation_exchange ]} + + % {cluster_size_3, [shuffle], + % [ + % dead_letter_into_stream, + % last_queue_confirms, + % target_queue_deleted, + % target_classic_queue_down, + % async_notify_settled_classic_queue, + % async_notify_settled_quorum_queue, + % async_notify_settled_stream, + % async_notify_unsettled_classic_queue, + % async_notify_unsettled_quorum_queue, + % async_notify_unsettled_stream, + % link_flow_control, + % classic_queue_on_old_node, + % classic_queue_on_new_node, + % quorum_queue_on_old_node, + % quorum_queue_on_new_node, + % maintenance, + % leader_transfer_quorum_queue_credit_single, + % leader_transfer_quorum_queue_credit_batches, + % leader_transfer_stream_credit_single, + % leader_transfer_stream_credit_batches, + % leader_transfer_quorum_queue_send, + % leader_transfer_stream_send, + % list_connections, + % detach_requeues_two_connections_classic_queue, + % detach_requeues_two_connections_quorum_queue, + % attach_to_down_quorum_queue + % ]}, + + % {metrics, [shuffle], + % [ + % auth_attempt_metrics + % ]} ]. %% ------------------------------------------------------------------- @@ -6255,8 +6255,8 @@ tcp_back_pressure_rabbitmq_internal_flow(QType, Config) -> ?assert(MsgsReady < Num), %% Use large buffers. This will considerably speed up receiving all messages (on Linux). - ok = inet:setopts(Socket, [{recbuf, 65536}, - {buffer, 65536}]), + % ok = inet:setopts(Socket, [{recbuf, 300_000}, + % {buffer, 300_000}]), %% When we resume the receiving client, we expect to receive all messages. ?assert(meck:validate(Mod)), ok = meck:unload(Mod),