Use server timestamp for queue score

This commit is contained in:
Chris Eager
2023-03-03 18:50:48 -06:00
committed by Chris Eager
parent 99e651e902
commit 437bc1358b
2 changed files with 4 additions and 4 deletions

View File

@@ -161,7 +161,7 @@ public class MessagesCache extends RedisClusterPubSubAdapter<String, String> imp
getMessageQueueMetadataKey(destinationUuid, destinationDevice),
getQueueIndexKey(destinationUuid, destinationDevice)),
List.of(messageWithGuid.toByteArray(),
String.valueOf(message.getTimestamp()).getBytes(StandardCharsets.UTF_8),
String.valueOf(message.getServerTimestamp()).getBytes(StandardCharsets.UTF_8),
guid.toString().getBytes(StandardCharsets.UTF_8))));
}