Packages

final class RedisOperationActor extends Actor with ActorLazyLogging

Implements execution of RedisOp (sequence of redis operations). Separate RedisOperationActor is spawned of every RedisOp and lives only to execute that single RedisOp.

Author: ghik Created: 11/04/16.

Linear Supertypes
ActorLazyLogging, Actor, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedisOperationActor
  2. ActorLazyLogging
  3. Actor
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new RedisOperationActor(connection: ActorRef)

Type Members

  1. type Receive = PartialFunction[Any, Unit]
    Definition Classes
    Actor

Value Members

  1. implicit val context: ActorContext
    Definition Classes
    Actor
  2. def handleOperation(op: RedisOp[Any], reserving: Boolean = false): Unit
  3. def postRestart(reason: Throwable): Unit
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  4. def postStop(): Unit
    Definition Classes
    RedisOperationActor → Actor
  5. def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  6. def preStart(): Unit
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  7. def receive: PartialFunction[Any, Unit]
    Definition Classes
    RedisOperationActor → Actor
  8. def releaseConnection(): Unit
  9. def respond(msg: Any): Unit
  10. implicit final val self: ActorRef
    Definition Classes
    Actor
  11. final def sender(): ActorRef
    Definition Classes
    Actor
  12. def supervisorStrategy: SupervisorStrategy
    Definition Classes
    Actor
  13. def unhandled(message: Any): Unit
    Definition Classes
    Actor
  14. def waitingForResponse[A, B](prevBatch: RedisBatch[A], nextStep: commons.Opt[(A) ⇒ RedisOp[B]], reserving: Boolean = false): Receive
  15. object log
    Definition Classes
    ActorLazyLogging