From ff04da0b24d3ded2f595de84ee34524553a32faf Mon Sep 17 00:00:00 2001 From: ticktock Date: Mon, 27 Sep 2010 19:05:35 -0400 Subject: [PATCH] Finished off Queue API --- .../src/main/scala/VoldemortStorageBackend.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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}) } }