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

fix for issue #480 Regression multibulk replies redis client with a new version of redisclient

Browse source
This commit is contained in:
Debasish Ghosh 2010-10-19 23:38:41 +05:30
parent ddfb15ea4b
commit 2e46c3eafd
4 changed files with 14 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-persistence/akka-persistence-redis/src/main/scala/RedisPubSubServer.scala
View file

@ -16,19 +16,19 @@ class Subscriber(client: RedisClient) extends Actor {
def receive = {
case Subscribe(channels) =>
client.subscribe(channels.head, channels.tail: _*)(callback)
self.reply(true)
self.reply_?(true)
case Register(cb) =>
callback = cb
self.reply(true)
self.reply_?(true)
case Unsubscribe(channels) =>
client.unsubscribe(channels.head, channels.tail: _*)
self.reply(true)
self.reply_?(true)
case UnsubscribeAll =>
client.unsubscribe
self.reply(true)
self.reply_?(true)
}
}
@ -36,7 +36,7 @@ class Publisher(client: RedisClient) extends Actor {
def receive = {
case Publish(channel, message) =>
client.publish(channel, message)
self.reply(true)
self.reply_?(true)
}
}