Sample session with redis pubsub implemented with redisclient

gistfile1.scala

Welcome to Scala version 2.10.2 (Java HotSpot(TM) 64-Bit Server VM, Java 1.6.0_51).
Type in expressions to have them evaluated.
Type :help for more information.

scala> import com.redis._
import com.redis._

scala> import akka.actor.{ Actor, ActorSystem, Props }
import akka.actor.{Actor, ActorSystem, Props}

scala> val ps = ActorSystem("pub")
ps: akka.actor.ActorSystem = akka://pub

scala> val ss = ActorSystem("sub")
ss: akka.actor.ActorSystem = akka://sub

scala> val p = ps.actorOf(Props(new Pub))
p: akka.actor.ActorRef = Actor[akka://pub/user/$a#2075877062]

scala> starting publishing service ..


scala> val s = ss.actorOf(Props(new Sub))
s: akka.actor.ActorRef = Actor[akka://sub/user/$a#724245975]

scala> starting subscription service ..
Got in Sub true


scala> p ! PublishMessage("a", "hello world")

scala> Got in Pub true


scala> s ! SubscribeMessage(List("a"))

scala> Got in Sub true
subscribed to a and count = 1


scala> 
scala> p ! PublishMessage("b", "+c")

scala> Got in Pub true


scala> p ! PublishMessage("b", "+d")

scala> Got in Pub true


scala> p ! PublishMessage("b", "-c")

scala> Got in Pub true


scala> p ! PublishMessage("b", "exit")

scala> Got in Pub true