rabbitmq-server/deps
David Ansari ae423721ad Fix flake will_delay_session_takeover
Prior to this commit, the following flake occurred in CI for
```
make -C deps/rabbitmq_mqtt ct-v5 t=cluster_size_1:will_delay_session_takeover
```

```
=== Location: [{v5_SUITE,will_delay_session_takeover,1473},
              {test_server,ts_tc,1793},
              {test_server,run_test_case_eval1,1302},
              {test_server,run_test_case_eval,1234}]
=== === Reason: {test_case_failed,"Received unexpected PUBLISH payload. Expected: <<\"will-3a\">> Got: <<\"will-4a\">>"}
```

The RabbitMQ logs for this single node test show:
```
2024-11-04 14:43:35.039196+00:00 [debug] <0.1334.0> MQTT accepting TCP connection <0.1334.0> (127.0.0.1:42576 -> 127.0.0.1:27005)
2024-11-04 14:43:35.039336+00:00 [debug] <0.1334.0> Received a CONNECT, client ID: c3, username: undefined, clean start: true, protocol version: 5, keepalive: 60, property names: []
2024-11-04 14:43:35.039438+00:00 [debug] <0.1334.0> MQTT connection 127.0.0.1:42576 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.039537+00:00 [debug] <0.1334.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.039729+00:00 [info] <0.1334.0> Accepted MQTT connection 127.0.0.1:42576 -> 127.0.0.1:27005 for client ID c3
2024-11-04 14:43:35.040297+00:00 [debug] <0.1337.0> MQTT accepting TCP connection <0.1337.0> (127.0.0.1:42580 -> 127.0.0.1:27005)
2024-11-04 14:43:35.040442+00:00 [debug] <0.1337.0> Received a CONNECT, client ID: c4, username: undefined, clean start: true, protocol version: 5, keepalive: 60, property names: []
2024-11-04 14:43:35.040534+00:00 [debug] <0.1337.0> MQTT connection 127.0.0.1:42580 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.040597+00:00 [debug] <0.1337.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.040793+00:00 [info] <0.1337.0> Accepted MQTT connection 127.0.0.1:42580 -> 127.0.0.1:27005 for client ID c4
2024-11-04 14:43:35.041463+00:00 [debug] <0.1340.0> MQTT accepting TCP connection <0.1340.0> (127.0.0.1:42596 -> 127.0.0.1:27005)
2024-11-04 14:43:35.041715+00:00 [debug] <0.1340.0> Received a CONNECT, client ID: c1, username: undefined, clean start: false, protocol version: 5, keepalive: 60, property names: ['Session-Expiry-Interval']
2024-11-04 14:43:35.041806+00:00 [debug] <0.1340.0> MQTT connection 127.0.0.1:42596 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.041881+00:00 [debug] <0.1340.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.041982+00:00 [warning] <0.1328.0> MQTT disconnecting client <<"127.0.0.1:42560 -> 127.0.0.1:27005">> with duplicate id 'c1'
2024-11-04 14:43:35.042062+00:00 [info] <0.1340.0> Accepted MQTT connection 127.0.0.1:42596 -> 127.0.0.1:27005 for client ID c1
2024-11-04 14:43:35.045624+00:00 [debug] <0.1345.0> MQTT accepting TCP connection <0.1345.0> (127.0.0.1:42602 -> 127.0.0.1:27005)
2024-11-04 14:43:35.045781+00:00 [debug] <0.1345.0> Received a CONNECT, client ID: c2, username: undefined, clean start: false, protocol version: 5, keepalive: 60, property names: ['Session-Expiry-Interval']
2024-11-04 14:43:35.045874+00:00 [debug] <0.1345.0> MQTT connection 127.0.0.1:42602 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.045943+00:00 [debug] <0.1345.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.046032+00:00 [warning] <0.1331.0> MQTT disconnecting client <<"127.0.0.1:42566 -> 127.0.0.1:27005">> with duplicate id 'c2'
2024-11-04 14:43:35.046281+00:00 [info] <0.1345.0> Accepted MQTT connection 127.0.0.1:42602 -> 127.0.0.1:27005 for client ID c2
2024-11-04 14:43:35.047063+00:00 [debug] <0.1350.0> MQTT accepting TCP connection <0.1350.0> (127.0.0.1:42614 -> 127.0.0.1:27005)
2024-11-04 14:43:35.047702+00:00 [debug] <0.1350.0> Received a CONNECT, client ID: c3, username: undefined, clean start: true, protocol version: 5, keepalive: 60, property names: ['Session-Expiry-Interval']
2024-11-04 14:43:35.047910+00:00 [debug] <0.1350.0> MQTT connection 127.0.0.1:42614 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.048467+00:00 [debug] <0.1350.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.049701+00:00 [info] <0.1350.0> Accepted MQTT connection 127.0.0.1:42614 -> 127.0.0.1:27005 for client ID c3
2024-11-04 14:43:35.050907+00:00 [warning] <0.1334.0> MQTT disconnecting client <<"127.0.0.1:42576 -> 127.0.0.1:27005">> with duplicate id 'c3'
2024-11-04 14:43:35.051248+00:00 [debug] <0.1353.0> MQTT accepting TCP connection <0.1353.0> (127.0.0.1:42626 -> 127.0.0.1:27005)
2024-11-04 14:43:35.051395+00:00 [debug] <0.1353.0> Received a CONNECT, client ID: c4, username: undefined, clean start: false, protocol version: 5, keepalive: 60, property names: ['Session-Expiry-Interval']
2024-11-04 14:43:35.051519+00:00 [debug] <0.1353.0> MQTT connection 127.0.0.1:42626 -> 127.0.0.1:27005 picked vhost using plugin_configuration_or_default_vhost
2024-11-04 14:43:35.051590+00:00 [debug] <0.1353.0> User 'guest' authenticated successfully by backend rabbit_auth_backend_internal
2024-11-04 14:43:35.051871+00:00 [info] <0.1353.0> Accepted MQTT connection 127.0.0.1:42626 -> 127.0.0.1:27005 for client ID c4
2024-11-04 14:43:35.051960+00:00 [warning] <0.1337.0> MQTT disconnecting client <<"127.0.0.1:42580 -> 127.0.0.1:27005">> with duplicate id 'c4'
2024-11-04 14:43:35.052689+00:00 [debug] <0.1337.0> sent Will Message to topic my/topic for MQTT client ID c4
2024-11-04 14:43:35.054119+00:00 [debug] <0.1334.0> sent Will Message to topic my/topic for MQTT client ID c3
```

We see nicely how RabbitMQ sends the will message for both c3 and c4.
However, the order in which RabbitMQ sends is not guaranteed.
Hence, we adapt the test expectation to not depend on the order of Will
messages being received.
2024-11-08 16:12:52 +01:00
..
amqp10_client Convert array from AMQP 1.0 to AMQP 0.9.1 2024-10-22 12:16:19 +02:00
amqp10_common Provide clear error message for reserved annotation keys 2024-10-16 14:14:04 +02:00
amqp_client Provide specific f. to fix client ssl options 2024-10-21 18:00:06 -04:00
oauth2_client Fix failing test cases 2024-10-09 11:01:09 -04:00
rabbit Merge pull request #12686 from rabbitmq/stream-coordinator-ra-local-query-infinity-timeout 2024-11-08 15:08:16 +01:00
rabbit_common Abort restart-cluster if something goes wrong 2024-11-04 00:34:50 -05:00
rabbitmq_amqp1_0 make: Restrict Erlang.mk plugin inclusion 2024-08-29 15:19:50 +02:00
rabbitmq_amqp_client Support AMQP 1.0 token renewal 2024-11-04 00:34:51 -05:00
rabbitmq_auth_backend_cache Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_auth_backend_http build(deps): bump org.springframework.boot:spring-boot-starter-parent 2024-11-04 00:34:47 -05:00
rabbitmq_auth_backend_ldap Merge pull request #12550 from rabbitmq/lukebakken/shellcheck-init-slapd 2024-10-22 00:56:30 -04:00
rabbitmq_auth_backend_oauth2 bazel run gazelle 2024-11-04 00:34:52 -05:00
rabbitmq_auth_mechanism_ssl Correct a couple of doc guide links 2024-08-15 16:04:46 -04:00
rabbitmq_aws make: Restrict Erlang.mk plugin inclusion 2024-08-29 15:19:50 +02:00
rabbitmq_cli Tests: set disk monitor as active in set_disk_free_limit_command_test 2024-11-06 16:59:19 +01:00
rabbitmq_codegen make: Remove show-upstream-git-fetch-url and co 2024-08-29 15:19:14 +02:00
rabbitmq_consistent_hash_exchange Strictly validate annotations 2024-09-18 12:42:27 +02:00
rabbitmq_ct_client_helpers make: Remove emptied rabbitmq-tools.mk 2024-08-29 15:19:14 +02:00
rabbitmq_ct_helpers Verify non-zero DNS and email SAN 2024-11-04 00:34:50 -05:00
rabbitmq_event_exchange Add AMQP 1.0 event exchange test 2024-11-04 00:34:49 -05:00
rabbitmq_federation queue_SUITE: use a different upstream for each queue on multi-federation tests 2024-11-04 00:34:49 -05:00
rabbitmq_federation_management Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_federation_prometheus test: wait for links and metrics in prometheus_rabbitmq_federation_collector_SUITE 2024-11-04 08:42:42 +01:00
rabbitmq_jms_topic_exchange Reorganize data in the Khepri store 2024-09-05 15:31:29 +02:00
rabbitmq_management Show session and link details for AMQP 1.0 connection 2024-11-07 15:11:42 +01:00
rabbitmq_management_agent rabbit_feature_flags: Introduce hard vs. soft required feature flags 2024-11-04 00:34:49 -05:00
rabbitmq_mqtt Fix flake will_delay_session_takeover 2024-11-08 16:12:52 +01:00
rabbitmq_peer_discovery_aws Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_peer_discovery_common Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_peer_discovery_consul rabbitmq_peer_discovery_{etcd,consul}: Fix error handling if Khepri is unsupported 2024-07-10 14:24:19 +02:00
rabbitmq_peer_discovery_etcd Fix some OTP-27 Dialyzer errors in rabbitmq_peer_discovery_etcd 2024-09-30 12:35:43 +02:00
rabbitmq_peer_discovery_k8s Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_prelaunch make: Correct rabbitmq_prelaunch/rabbitmq_stream_common deps 2024-09-30 12:35:42 +02:00
rabbitmq_prometheus rabbit_prometheus_http_SUITE: Start broker once in `special_chars` group 2024-11-04 00:34:49 -05:00
rabbitmq_random_exchange Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_recent_history_exchange rabbitmq_recent_history_exchange: Respect RABBITMQ_METADATA_STORE in system_SUITE 2024-09-05 15:31:35 +02:00
rabbitmq_sharding Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_shovel Fix AMQP 1.0 shovel 2024-09-25 18:06:22 +02:00
rabbitmq_shovel_management Minor fix: GET/HEAD method on non existing shovel crash 2024-08-29 20:05:47 +00:00
rabbitmq_shovel_prometheus Make sure Makefile output correct application config for shovel and federation prometheus 2024-08-08 01:26:49 -04:00
rabbitmq_stomp Revert "Log errors from `ranch:handshake`" (#12304) 2024-09-13 17:07:57 +02:00
rabbitmq_stream Squash dialyzer warning 2024-11-07 18:17:47 +01:00
rabbitmq_stream_common make: Correct rabbitmq_prelaunch/rabbitmq_stream_common deps 2024-09-30 12:35:42 +02:00
rabbitmq_stream_management build(deps): bump org.apache.maven.plugins:maven-surefire-plugin 2024-11-04 18:17:42 +00:00
rabbitmq_top Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_tracing Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_trust_store Fix OTP-27 Dialyzer errors in rabbitmq_trust_store 2024-09-30 12:35:42 +02:00
rabbitmq_web_dispatch Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_web_mqtt Expose AMQP connection metrics 2024-11-02 19:08:24 +01:00
rabbitmq_web_mqtt_examples Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
rabbitmq_web_stomp Allow for tagged values for a few more rabbitmq.conf settings 2024-08-13 16:27:00 -04:00
rabbitmq_web_stomp_examples Cleanup .gitignore files for the monorepo 2024-06-28 12:00:52 +02:00
trust_store_http Fix OTP-27 Dialyzer errors in trust_store_http 2024-09-30 12:35:42 +02:00