diff --git a/akka-persistence/akka-persistence-voldemort/src/main/scala/VoldemortStorageBackend.scala b/akka-persistence/akka-persistence-voldemort/src/main/scala/VoldemortStorageBackend.scala index 92d8d4a2d2..9883eb121f 100644 --- a/akka-persistence/akka-persistence-voldemort/src/main/scala/VoldemortStorageBackend.scala +++ b/akka-persistence/akka-persistence-voldemort/src/main/scala/VoldemortStorageBackend.scala @@ -390,8 +390,8 @@ MapStorageBackend[Array[Byte], Array[Byte]] with Range(head, tail) } else { //queue has wrapped - val headRange = Range(head, Integer.MAX_VALUE) - (if (tail > 0) {headRange ++ Range(0, tail - 1)} else {headRange}) + val headRange = Range.inclusive(head, Integer.MAX_VALUE) + (if (tail > 0) {headRange ++ Range(0, tail)} else {headRange}) } }