@@ -53,19 +53,19 @@ ValueTask PublishAsync()
5353 }
5454
5555 await _channel . ConfirmSelectAsync ( ) ;
56- Assert . Equal ( 1ul , _channel . NextPublishSeqNo ) ;
56+ Assert . Equal ( 1ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
5757 await PublishAsync ( ) ;
58- Assert . Equal ( 2ul , _channel . NextPublishSeqNo ) ;
58+ Assert . Equal ( 2ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
5959 await PublishAsync ( ) ;
60- Assert . Equal ( 3ul , _channel . NextPublishSeqNo ) ;
60+ Assert . Equal ( 3ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
6161
6262 await _channel . ConfirmSelectAsync ( ) ;
6363 await PublishAsync ( ) ;
64- Assert . Equal ( 4ul , _channel . NextPublishSeqNo ) ;
64+ Assert . Equal ( 4ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
6565 await PublishAsync ( ) ;
66- Assert . Equal ( 5ul , _channel . NextPublishSeqNo ) ;
66+ Assert . Equal ( 5ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
6767 await PublishAsync ( ) ;
68- Assert . Equal ( 6ul , _channel . NextPublishSeqNo ) ;
68+ Assert . Equal ( 6ul , await _channel . GetNextPublishSequenceNumberAsync ( ) ) ;
6969 }
7070
7171 [ Theory ]
@@ -80,7 +80,7 @@ public async Task TestDeliveryTagDiverged_GH1043(ushort correlationIdLength)
8080 await _channel . ConfirmSelectAsync ( ) ;
8181
8282 var properties = new BasicProperties ( ) ;
83- // _output.WriteLine("Client delivery tag {0}", _channel.NextPublishSeqNo );
83+ // _output.WriteLine("Client delivery tag {0}", await _channel.GetNextPublishSequenceNumberAsync() );
8484 await _channel . BasicPublishAsync ( exchange : "sample" , routingKey : string . Empty ,
8585 mandatory : false , basicProperties : properties , body : body ) ;
8686 await _channel . WaitForConfirmsOrDieAsync ( ) ;
@@ -91,7 +91,7 @@ await _channel.BasicPublishAsync(exchange: "sample", routingKey: string.Empty,
9191 {
9292 CorrelationId = new string ( 'o' , correlationIdLength )
9393 } ;
94- // _output.WriteLine("Client delivery tag {0}", _channel.NextPublishSeqNo );
94+ // _output.WriteLine("Client delivery tag {0}", await _channel.GetNextPublishSequenceNumberAsync() );
9595 await _channel . BasicPublishAsync ( "sample" , string . Empty , false , properties , body ) ;
9696 await _channel . WaitForConfirmsOrDieAsync ( ) ;
9797 }
@@ -101,7 +101,7 @@ await _channel.BasicPublishAsync(exchange: "sample", routingKey: string.Empty,
101101 }
102102
103103 properties = new BasicProperties ( ) ;
104- // _output.WriteLine("Client delivery tag {0}", _channel.NextPublishSeqNo );
104+ // _output.WriteLine("Client delivery tag {0}", await _channel.GetNextPublishSequenceNumberAsync() );
105105 await _channel . BasicPublishAsync ( "sample" , string . Empty , false , properties , body ) ;
106106 await _channel . WaitForConfirmsOrDieAsync ( ) ;
107107 // _output.WriteLine("I'm done...");
0 commit comments