RedisSubscriberActor

abstract def onMessage(m: Message): Unit

abstract def onPMessage(pm: PMessage): Unit

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val address: InetSocketAddress

def aroundPostRestart(reason: Throwable): Unit

def aroundPostStop(): Unit

def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

def aroundPreStart(): Unit

def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

final def asInstanceOf[T0]: T0

var bufferRead: ByteString

val bufferWrite: ByteStringBuilder

var channelsSubscribed: Set[String]

Keep states of channels and actor in case of connection reset

def cleanState(): Unit

def clone(): AnyRef

def connected: Receive

def connecting: Receive

implicit val context: ActorContext

def decodeReplies(dataByteString: ByteString): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def initConnectedBuffer(): Unit

final def isInstanceOf[T0]: Boolean

def log: LoggingAdapter

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def onAddressChanged(addr: InetSocketAddress): Unit

def onClosingConnectionClosed(): Unit

def onConnectWrite(): ByteString

def onConnected(cmd: Connected): Unit

def onConnectedCommandFailed(commandFailed: CommandFailed): Unit

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

def onConnectingCommandFailed(cmdFailed: CommandFailed): Unit

def onConnectionClosed(): Unit

def onConnectionClosed(c: ConnectionClosed): Unit

def onDataReceived(dataByteString: ByteString): Unit

def onDataReceivedOnClosingConnection(dataByteString: ByteString): Unit

def onDecodedReply(reply: RedisReply): Unit

def onErrorReply(error: Error): Unit

def onWriteSent(): Unit

var patternsSubscribed: Set[String]

def postRestart(reason: Throwable): Unit

def postStop(): Unit

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

def preStart(): Unit

def psubscribe(patterns: String*): Unit

def punsubscribe(patterns: String*): Unit

var readyToWrite: Boolean

def receive: PartialFunction[Any, Unit]

def reconnect(): Unit

def reconnectDuration: FiniteDuration

def restartConnection(): Unit

def scheduleReconnect(): Unit

implicit final val self: ActorRef

final def sender(): ActorRef

def subscribe(channels: String*): Unit

def supervisorStrategy: SupervisorStrategy

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

val tcp: ActorRef

var tcpWorker: ActorRef

def toString(): String

def tryInitialWrite(): Unit

def tryWrite(): Unit

def unhandled(message: Any): Unit

def unsubscribe(channels: String*): Unit

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def write(byteString: ByteString): Unit

def writing: Receive