diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-10-22 02:40:48 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-10-22 02:46:12 +0300 |
| commit | 4eff13c961ba033c686b84fe8c914fef0376a446 (patch) | |
| tree | 34cbe2f9da911b95e0a1ed167c7e3562ee1c4a81 | |
| parent | d9bfc86e2536373a67e5cc7900887397705f68db (diff) | |
| download | rabbitmq-server-git-4eff13c961ba033c686b84fe8c914fef0376a446.tar.gz | |
Wording
| -rw-r--r-- | test/unit_inbroker_non_parallel_SUITE.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/unit_inbroker_non_parallel_SUITE.erl b/test/unit_inbroker_non_parallel_SUITE.erl index 5504265da9..4038eb9a9c 100644 --- a/test/unit_inbroker_non_parallel_SUITE.erl +++ b/test/unit_inbroker_non_parallel_SUITE.erl @@ -604,7 +604,7 @@ head_message_timestamp1(_Config) -> %% Set up event receiver for queue dummy_event_receiver:start(self(), [node()], [queue_stats]), - %% Check timestamp is empty when queue is empty + %% the head timestamp field is empty when queue is empty empty test_queue_statistics_receive_event(QPid, fun (E) -> (proplists:get_value(name, E) == QRes) @@ -617,7 +617,7 @@ head_message_timestamp1(_Config) -> after ?TIMEOUT -> throw(failed_to_receive_tx_select_ok) end, - %% Publish two messages and check timestamp is that of first message + %% Publish two messages and check that the timestamp is that of first message rabbit_channel:do(Ch, #'basic.publish'{exchange = <<"">>, routing_key = QName}, rabbit_basic:build_content(#'P_basic'{timestamp = 1}, <<"">>)), @@ -636,7 +636,7 @@ head_message_timestamp1(_Config) -> (proplists:get_value(head_message_timestamp, E) == 1) end), - %% Get first message and check timestamp is that of second message + %% Consume a message and check that the timestamp is now that of the second message rabbit_channel:do(Ch, #'basic.get'{queue = QName, no_ack = true}), test_queue_statistics_receive_event(QPid, fun (E) -> @@ -645,7 +645,7 @@ head_message_timestamp1(_Config) -> (proplists:get_value(head_message_timestamp, E) == 2) end), - %% Get second message and check timestamp is empty again + %% Consume one more message and check again rabbit_channel:do(Ch, #'basic.get'{queue = QName, no_ack = true}), test_queue_statistics_receive_event(QPid, fun (E) -> |