How Transactions are supported in the client about scala-redis HOT 5 CLOSED

Have a look at https://github.com/debasishg/scala-redis/blob/master/src/main/scala/com/redis/RedisClient.scala#L68 .. pipeline supports pipelining with transactions. Without transactions, pipelining is supported with pipelineNoMulti .. https://github.com/debasishg/scala-redis/blob/master/src/main/scala/com/redis/RedisClient.scala#L119 ..

Hope this helps.

from scala-redis.

Thanks, I could find a sample also in the test cases https://github.com/debasishg/scala-redis/blob/master/src/test/scala/com/redis/PipelineSpec.scala

However, my problem is that I want to execute 3 commands, the result of the first command should be the input for the successor 2 commands, when I tried this, the result of the first command resulted in "NullPointerException":

val result = redisClient.pipeline { c =>
  c.rpush(subscribersList, userData) match {
    case x @ Some(i) =>
      c.set(email, i)
      c.set(token, i)
      x
    case None => None
  }
}

Also what is the return of this pipeline function, what is the Option[List[Any]]?

Thanks,

from scala-redis.

Thanks for reporting .. will take a look over the weekend .. Will it be possible to give a failing test case which I can run and see the problem ?

from scala-redis.

I don't think you can do arbitrary logic within a redis transaction. And redid returns a list containing the execution result of each of them. I think you can have an equivalent effect with the following ..

describe("pipeline5") {
  it("should do pipelined commands") {
    val res = 
      r.rpush("subscribersList", "subs1") match {
        case x @ Some(i) =>
          r.pipeline { p =>
            p.set("email", i)
            p.set("token", i)
            p.llen("subscribersList")
          }.get
        case None => List()
      }
    println(res)
  }
}

and this will print List(true, true, Some(1))

from scala-redis.

Thanks a lot, I already went ti this approach in temporary basis, however after your confirmation, I will stick to it, thanks a gain.

from scala-redis.