RedisClientActor

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. val address: InetSocketAddress

   Definition Classes

   RedisClientActor → RedisWorkerIO

7. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

8. val bufferWrite: ByteStringBuilder

   Definition Classes

   RedisWorkerIO

9. def cleanState(): Unit

   Definition Classes

   RedisWorkerIO

10. def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

11. def connected: Receive

    Definition Classes

    RedisWorkerIO

12. def connecting: Receive

    Definition Classes

    RedisWorkerIO

13. implicit val context: ActorContext

    Definition Classes

    Actor

14. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

16. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

17. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

18. def hashCode(): Int

    Definition Classes

    AnyRef → Any

19. def initConnectedBuffer(): Unit

    Definition Classes

    RedisWorkerIO

20. def initRepliesDecoder(): ActorRef

21. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

22. def killOldRepliesDecoder(): Unit

23. val log: LoggingAdapter

    Definition Classes

    ActorLogging

24. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

25. final def notify(): Unit

    Definition Classes

    AnyRef

26. final def notifyAll(): Unit

    Definition Classes

    AnyRef

27. var oldRepliesDecoder: Option[ActorRef]

28. def onAddressChanged(addr: InetSocketAddress): Unit

    Definition Classes

    RedisWorkerIO

29. def onClosingConnectionClosed(): Unit

    Definition Classes

    RedisClientActor → RedisWorkerIO

30. def onConnectWrite(): ByteString

    Definition Classes

    RedisClientActor → RedisWorkerIO

31. def onConnected(cmd: Connected): Unit

    Definition Classes

    RedisWorkerIO

32. def onConnectedCommandFailed(commandFailed: CommandFailed): Unit

    O/S buffer was full Maybe to much data in the Command ?

    O/S buffer was full Maybe to much data in the Command ?

    Definition Classes

    RedisWorkerIO

33. def onConnectingCommandFailed(cmdFailed: CommandFailed): Unit

    Definition Classes

    RedisWorkerIO

34. def onConnectionClosed(): Unit

    Definition Classes

    RedisClientActor → RedisWorkerIO

35. def onConnectionClosed(c: ConnectionClosed): Unit

    Definition Classes

    RedisWorkerIO

36. def onDataReceived(dataByteString: ByteString): Unit

    Definition Classes

    RedisClientActor → RedisWorkerIO

37. def onDataReceivedOnClosingConnection(dataByteString: ByteString): Unit

    Definition Classes

    RedisClientActor → RedisWorkerIO

38. def onWriteSent(): Unit

    Definition Classes

    RedisClientActor → RedisWorkerIO

39. def postRestart(reason: Throwable): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

40. def postStop(): Unit

    Definition Classes

    RedisWorkerIO → Actor

41. def preRestart(reason: Throwable, message: Option[Any]): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

42. def preStart(): Unit

    Definition Classes

    RedisWorkerIO → Actor

43. var queuePromises: Queue[Operation[_, _]]

44. var readyToWrite: Boolean

    Definition Classes

    RedisWorkerIO

45. def receive: PartialFunction[Any, Unit]

    Definition Classes

    RedisWorkerIO → Actor

46. def reconnect(): Unit

    Definition Classes

    RedisWorkerIO

47. def reconnectDuration: FiniteDuration

    Definition Classes

    RedisWorkerIO

48. var repliesDecoder: ActorRef

49. def restartConnection(): Unit

    Definition Classes

    RedisWorkerIO

50. def scheduleReconnect(): Unit

    Definition Classes

    RedisWorkerIO

51. implicit final val self: ActorRef

    Definition Classes

    Actor

52. final def sender: ActorRef

    Definition Classes

    Actor

53. val supervisorStrategy: OneForOneStrategy

    Definition Classes

    RedisClientActor → Actor

54. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

55. val tcp: ActorRef

    Definition Classes

    RedisWorkerIO

56. var tcpWorker: ActorRef

    Definition Classes

    RedisWorkerIO

57. def toString(): String

    Definition Classes

    AnyRef → Any

58. def tryInitialWrite(): Unit

    Definition Classes

    RedisWorkerIO

59. def tryWrite(): Unit

    Definition Classes

    RedisWorkerIO

60. def unhandled(message: Any): Unit

    Definition Classes

    Actor

61. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

62. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

63. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

64. def write(byteString: ByteString): Unit

    Definition Classes

    RedisWorkerIO

65. def writing: Receive

    Definition Classes

    RedisClientActor → RedisWorkerIO