@@ -149,7 +149,7 @@ public async Task GivenFileStorageMetadata_WhenQueueingWithDatabaseError_ExpectT
149
149
_cancellationTokenSource . Token . WaitHandle . WaitOne ( ) ;
150
150
payloadAssembler . Dispose ( ) ;
151
151
152
- _logger . VerifyLoggingMessageBeginsWith ( $ "Number of buckets active : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
152
+ _logger . VerifyLoggingMessageBeginsWith ( $ "Number of incomplete payloads waiting for processing : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
153
153
}
154
154
155
155
[ RetryFact ( 10 , 200 ) ]
@@ -167,7 +167,7 @@ public async Task GivenAPayloadThatHasNotCompleteUploads_WhenProcessedByTimedEve
167
167
await Task . Delay ( 1001 ) ;
168
168
payloadAssembler . Dispose ( ) ;
169
169
170
- _logger . VerifyLoggingMessageBeginsWith ( $ "Number of buckets active : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
170
+ _logger . VerifyLoggingMessageBeginsWith ( $ "Number of incomplete payloads waiting for processing : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
171
171
_logger . VerifyLoggingMessageBeginsWith ( $ "Bucket A sent to processing queue", LogLevel . Information , Times . Never ( ) ) ;
172
172
}
173
173
@@ -183,7 +183,7 @@ public async Task GivenAPayloadThatHasCompletedUploads_WhenProcessedByTimedEvent
183
183
var result = payloadAssembler . Dequeue ( _cancellationTokenSource . Token ) ;
184
184
payloadAssembler . Dispose ( ) ;
185
185
186
- _logger . VerifyLoggingMessageBeginsWith ( $ "Number of buckets active : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
186
+ _logger . VerifyLoggingMessageBeginsWith ( $ "Number of incomplete payloads waiting for processing : 1.", LogLevel . Trace , Times . AtLeastOnce ( ) ) ;
187
187
Assert . Single ( result . Files ) ;
188
188
_logger . VerifyLoggingMessageBeginsWith ( $ "Bucket A sent to processing queue with { result . Count } files", LogLevel . Information , Times . AtLeastOnce ( ) ) ;
189
189
}
0 commit comments