From 1ef3049665b2be88dc76bbac2e8c0271e231f293 Mon Sep 17 00:00:00 2001
From: Debasish Ghosh <debasish@debasishg.(none)>
Date: Tue, 14 Sep 2010 17:33:11 +0530
Subject: [PATCH] fixed bug in PersistentSortedSet implemnetation of redis

---
 .../src/main/scala/RedisStorageBackend.scala      | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala b/akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala
index 61595ec21f..9fd3142019 100644
--- a/akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala
+++ b/akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala
@@ -302,13 +302,23 @@ private [akka] object RedisStorageBackend extends
   // add item to sorted set identified by name
   def zadd(name: String, zscore: String, item: Array[Byte]): Boolean = withErrorHandling {
     db.zadd(name, zscore, byteArrayToString(item))
-      .map { case 1 => true }.getOrElse(false)
+      .map { e => 
+        e match {
+          case 1 => true
+          case _ => false 
+        }
+      }.getOrElse(false)
   }
 
   // remove item from sorted set identified by name
   def zrem(name: String, item: Array[Byte]): Boolean = withErrorHandling {
     db.zrem(name, byteArrayToString(item))
-      .map { case 1 => true }.getOrElse(false)
+      .map { e => 
+        e match {
+          case 1 => true
+          case _ => false 
+        }
+      }.getOrElse(false)
   }
 
   // cardinality of the set identified by name
@@ -349,6 +359,7 @@ private [akka] object RedisStorageBackend extends
       case e: java.lang.NullPointerException =>
         throw new StorageException("Could not connect to Redis server")
       case e =>
+        e.printStackTrace
         throw new StorageException("Error in Redis: " + e.getMessage)
     }
   }