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

Merge branch 'master' of git@github.com:jboner/akka into workstealing

Browse source
This commit is contained in:
Jan Van Besien 2010-03-30 20:43:35 +02:00
commit 1f4ddfc9fc
4 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala
View file

@ -261,7 +261,7 @@ private [akka] object RedisStorageBackend extends
}
override def incrementByAtomically(name: String, by: Int): Option[Int] = withErrorHandling {
db.incrBy(new String(encode(name.getBytes)), by) match {
db.incrby(new String(encode(name.getBytes)), by) match {
case Some(i) => Some(i)
case None =>
throw new Predef.IllegalArgumentException(name + " exception in incrby")
@ -277,7 +277,7 @@ private [akka] object RedisStorageBackend extends
}
override def decrementByAtomically(name: String, by: Int): Option[Int] = withErrorHandling {
db.decrBy(new String(encode(name.getBytes)), by) match {
db.decrby(new String(encode(name.getBytes)), by) match {
case Some(i) => Some(i)
case None =>
throw new Predef.IllegalArgumentException(name + " exception in decrby")
@ -390,7 +390,7 @@ private [akka] object RedisStorageBackend extends
}
}
def flushDB = withErrorHandling(db.flushDb)
def flushDB = withErrorHandling(db.flushdb)
private def withErrorHandling[T](body: => T): T = {
try {

BIN
embedded-repo/com/redis/redisclient/1.2-SNAPSHOT/redisclient-1.2-SNAPSHOT.jar
View file

Binary file not shown.

BIN
embedded-repo/com/redis/redisclient/1.2/redisclient-1.2.jar Normal file
View file

Binary file not shown.

2
project/build/AkkaProject.scala
View file

@ -249,7 +249,7 @@ class AkkaParent(info: ProjectInfo) extends DefaultProject(info) {
}
class AkkaRedisProject(info: ProjectInfo) extends DefaultProject(info) {
val redis = "com.redis" % "redisclient" % "1.2-SNAPSHOT" % "compile"
val redis = "com.redis" % "redisclient" % "1.2" % "compile"
override def testOptions = TestFilter((name: String) => name.endsWith("Test")) :: Nil
lazy val dist = deployTask(info, distPath) dependsOn(`package`) describedAs("Deploying")
}