From 6335430c8119e0d23682bd102926ac97f5cdda68 Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Sun, 11 Feb 2018 15:10:21 -0800 Subject: [PATCH] fixed https://github.com/Netflix/dyno-queues/issues/19 --- .../main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java index 6a6dd48..e19462e 100644 --- a/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java +++ b/dyno-queues-redis/src/main/java/com/netflix/dyno/queues/redis/RedisDynoQueue.java @@ -163,7 +163,7 @@ public List push(final List messages) { for (Message message : messages) { String json = om.writeValueAsString(message); quorumConn.hset(messageStoreKey, message.getId(), json); - double priority = message.getPriority() / 100; + double priority = message.getPriority() / 100.0; double score = Long.valueOf(clock.millis() + message.getTimeout()).doubleValue() + priority; String shard = getNextShard(); String queueShard = getQueueShardKey(queueName, shard);