raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Finished off Queue API

Browse source
This commit is contained in:
ticktock 2010-09-27 19:05:35 -04:00
parent 9856f16900
commit ff04da0b24
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-persistence/akka-persistence-voldemort/src/main/scala/VoldemortStorageBackend.scala
View file

@ -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})
}
}