diff options
| author | Michael Klishin <klishinm@vmware.com> | 2023-03-17 20:17:34 +0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-03-17 20:17:34 +0400 |
| commit | 25c15bf5c3a9e1eb5093c52a64078d6fd8709751 (patch) | |
| tree | afbf8f147b16b2f05f88c9d4b2a155209eb3752f | |
| parent | 1a7dbdf1b0e85d6c9020e2e617249bb156ddc894 (diff) | |
| parent | f5564da94ad87b82166d433c4ab2e6bc977c3e66 (diff) | |
| download | rabbitmq-server-git-25c15bf5c3a9e1eb5093c52a64078d6fd8709751.tar.gz | |
Merge pull request #7663 from rabbitmq/fix-flaky-rabbit_mqtt_qos0_queue_overflow
Fix flaky test rabbit_mqtt_qos0_queue_overflow
| -rw-r--r-- | deps/rabbitmq_mqtt/test/reader_SUITE.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbitmq_mqtt/test/reader_SUITE.erl b/deps/rabbitmq_mqtt/test/reader_SUITE.erl index fb71eae375..1f5ba05d98 100644 --- a/deps/rabbitmq_mqtt/test/reader_SUITE.erl +++ b/deps/rabbitmq_mqtt/test/reader_SUITE.erl @@ -247,7 +247,7 @@ rabbit_mqtt_qos0_queue_overflow(Config) -> ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, rabbit_mqtt_qos0_queue), Topic = atom_to_binary(?FUNCTION_NAME), - Msg = binary:copy(<<"x">>, 1000), + Msg = binary:copy(<<"x">>, 2000), NumMsgs = 10_000, %% Provoke TCP back-pressure from client to server by using very small buffers. @@ -269,7 +269,7 @@ rabbit_mqtt_qos0_queue_overflow(Config) -> end, lists:seq(1, NumMsgs)), %% Give the server some time to process (either send or drop) the messages. - timer:sleep(2000), + timer:sleep(2500), %% Let's resume the receiving client to receive any remaining messages that did %% not get dropped. |