Add a missing join to testTrimOnFullPrimaryQueue

This commit is contained in:
Ravi Khadiwala 2025-03-11 17:25:20 -05:00 committed by ravi-signal
parent e3160bc717
commit dbd14481ed
1 changed files with 1 additions and 1 deletions

View File

@ -313,7 +313,7 @@ class MessagePersisterTest {
.toList();
final long cacheSize = cachedMessages.stream().mapToLong(MessageProtos.Envelope::getSerializedSize).sum();
for (MessageProtos.Envelope envelope : cachedMessages) {
messagesCache.insert(UUID.fromString(envelope.getServerGuid()), DESTINATION_ACCOUNT_UUID, Device.PRIMARY_ID, envelope);
messagesCache.insert(UUID.fromString(envelope.getServerGuid()), DESTINATION_ACCOUNT_UUID, Device.PRIMARY_ID, envelope).join();
}
final long expectedClearedBytes = (long) (cacheSize * EXTRA_ROOM_RATIO);