Open awrank opened 10 years ago
PubSub functionality on top of Akka Actors. (This means separate RedisClient will be used for Subscriber).
For consumer register separate custom actor that will receive messages.
something like this (new trait that client will extend, simplified):
trait PubSub { def subscribe(channels: String*, listener: ActorRef): Future def publish(channel: String, msg: Any): Future }
+1
Tolsi
commented
7 years ago Tolsi
commented
7 years ago
PubSub functionality on top of Akka Actors. (This means separate RedisClient will be used for Subscriber).
For consumer register separate custom actor that will receive messages.
something like this (new trait that client will extend, simplified):
trait PubSub { def subscribe(channels: String*, listener: ActorRef): Future def publish(channel: String, msg: Any): Future }