@@ -589,7 +589,7 @@ head_message_timestamp1(_Config) ->
589589 % % Set up event receiver for queue
590590 dummy_event_receiver :start (self (), [node ()], [queue_stats ]),
591591
592- % % Check timestamp is empty when queue is empty
592+ % % the head timestamp field is empty when queue is empty empty
593593 test_queue_statistics_receive_event (QPid ,
594594 fun (E ) ->
595595 (proplists :get_value (name , E ) == QRes )
@@ -602,7 +602,7 @@ head_message_timestamp1(_Config) ->
602602 after ? TIMEOUT -> throw (failed_to_receive_tx_select_ok )
603603 end ,
604604
605- % % Publish two messages and check timestamp is that of first message
605+ % % Publish two messages and check that the timestamp is that of first message
606606 rabbit_channel :do (Ch , # 'basic.publish' {exchange = <<" " >>,
607607 routing_key = QName },
608608 rabbit_basic :build_content (# 'P_basic' {timestamp = 1 }, <<" " >>)),
@@ -621,7 +621,7 @@ head_message_timestamp1(_Config) ->
621621 (proplists :get_value (head_message_timestamp , E ) == 1 )
622622 end ),
623623
624- % % Get first message and check timestamp is that of second message
624+ % % Consume a message and check that the timestamp is now that of the second message
625625 rabbit_channel :do (Ch , # 'basic.get' {queue = QName , no_ack = true }),
626626 test_queue_statistics_receive_event (QPid ,
627627 fun (E ) ->
@@ -630,7 +630,7 @@ head_message_timestamp1(_Config) ->
630630 (proplists :get_value (head_message_timestamp , E ) == 2 )
631631 end ),
632632
633- % % Get second message and check timestamp is empty again
633+ % % Consume one more message and check again
634634 rabbit_channel :do (Ch , # 'basic.get' {queue = QName , no_ack = true }),
635635 test_queue_statistics_receive_event (QPid ,
636636 fun (E ) ->
0 commit comments