etaty / rediscala

Non-blocking, Reactive Redis driver for Scala (with Sentinel support)
Apache License 2.0
790 stars 142 forks source link

Transaction not worked #190

Closed tonyzhang2020 closed 7 years ago

tonyzhang2020 commented 7 years ago

Hi,I found an issue when I use the Transaction api,just run the example code :

val redisTransaction = redis.transaction() // new TransactionBuilder
  redisTransaction.watch("key")
  val set = redisTransaction.set("key", "abcValue")
  val decr = redisTransaction.decr("key")
  val get = redisTransaction.get("key")
  redisTransaction.exec()

Console printed: [MySpec-akka.actor.default-dispatcher-7] [akka://MySpec/user/RedisClient-$a] Message [redis.Transaction] without sender to Actor[akka://MySpec/user/RedisClient-$a#-198544998] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.

Maven dependencies:

  <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-actor_2.11</artifactId>
            <version>2.5.2</version>
        </dependency>
 <dependency>
            <groupId>com.github.etaty</groupId>
            <artifactId>rediscala_2.11</artifactId>
            <version>1.8.0</version>
        </dependency>

By the way,the code is run in akka testkit.