fixed #19

Netflix · Feb 11, 2018 · 6335430 · 6335430
1 parent 267567b
commit 6335430
Showing 1 changed file with 1 addition and 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
@@ -163,7 +163,7 @@ public List<String> push(final List<Message> 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);