RedisSubscriberActorWithCallback

Instance Constructors

new RedisSubscriberActorWithCallback(address: InetSocketAddress, channels: Seq[String], patterns: Seq[String], messageCallback: (Message) ⇒ Unit, pmessageCallback: (PMessage) ⇒ Unit, authPassword: Option[String] = None, onConnectStatus: (Boolean) ⇒ Unit)

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
val address: InetSocketAddress

Definition Classes
RedisWorkerIO
def aroundPostRestart(reason: Throwable): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPostStop(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreStart(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

Attributes
protected[akka]
Definition Classes
Actor
final def asInstanceOf[T0]: T0

Definition Classes
Any
var bufferRead: ByteString

Definition Classes
DecodeReplies
val bufferWrite: ByteStringBuilder

Definition Classes
RedisWorkerIO
var channelsSubscribed: Set[String]

Keep states of channels and actor in case of connection reset
Keep states of channels and actor in case of connection reset

Definition Classes
RedisSubscriberActor
def cleanState(): Unit

Definition Classes
RedisWorkerIO
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def connected: Receive

Definition Classes
RedisWorkerIO
def connecting: Receive

Definition Classes
RedisWorkerIO
implicit val context: ActorContext

Definition Classes
Actor
def decodeReplies(dataByteString: ByteString): Unit

Definition Classes
DecodeReplies
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def initConnectedBuffer(): Unit

Definition Classes
RedisWorkerIO
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def log: LoggingAdapter

Definition Classes
ActorLogging
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def onAddressChanged(addr: InetSocketAddress): Unit

Definition Classes
RedisWorkerIO
def onClosingConnectionClosed(): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO
def onConnectWrite(): ByteString

Definition Classes
RedisSubscriberActor → RedisWorkerIO
def onConnected(cmd: Connected): Unit

Definition Classes
RedisWorkerIO
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
def onConnectingCommandFailed(cmdFailed: CommandFailed): Unit

Definition Classes
RedisWorkerIO
def onConnectionClosed(): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO
def onConnectionClosed(c: ConnectionClosed): Unit

Definition Classes
RedisWorkerIO
def onDataReceived(dataByteString: ByteString): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO
def onDataReceivedOnClosingConnection(dataByteString: ByteString): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO
def onDecodedReply(reply: RedisReply): Unit

Definition Classes
RedisSubscriberActor → DecodeReplies
def onErrorReply(error: Error): Unit

Definition Classes
RedisSubscriberActor
def onMessage(m: Message): Unit

Definition Classes
RedisSubscriberActorWithCallback → RedisSubscriberActor
def onPMessage(pm: PMessage): Unit

Definition Classes
RedisSubscriberActorWithCallback → RedisSubscriberActor
def onWriteSent(): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO
var patternsSubscribed: Set[String]

Definition Classes
RedisSubscriberActor
def postRestart(reason: Throwable): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def postStop(): Unit

Definition Classes
RedisWorkerIO → Actor
def preRestart(reason: Throwable, message: Option[Any]): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preStart(): Unit

Definition Classes
RedisSubscriberActor → RedisWorkerIO → Actor
def psubscribe(patterns: String*): Unit

Definition Classes
RedisSubscriberActor
def punsubscribe(patterns: String*): Unit

Definition Classes
RedisSubscriberActor
var readyToWrite: Boolean

Definition Classes
RedisWorkerIO
def receive: PartialFunction[Any, Unit]

Definition Classes
RedisWorkerIO → Actor
def reconnect(): Unit

Definition Classes
RedisWorkerIO
def reconnectDuration: FiniteDuration

Definition Classes
RedisWorkerIO
def restartConnection(): Unit

Definition Classes
RedisWorkerIO
def scheduleReconnect(): Unit

Definition Classes
RedisWorkerIO
implicit final val self: ActorRef

Definition Classes
Actor
final def sender(): ActorRef

Definition Classes
Actor
def subscribe(channels: String*): Unit

Definition Classes
RedisSubscriberActor
def supervisorStrategy: SupervisorStrategy

Definition Classes
Actor
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val tcp: ActorRef

Definition Classes
RedisWorkerIO
var tcpWorker: ActorRef

Definition Classes
RedisWorkerIO
def toString(): String

Definition Classes
AnyRef → Any
def tryInitialWrite(): Unit

Definition Classes
RedisWorkerIO
def tryWrite(): Unit

Definition Classes
RedisWorkerIO
def unhandled(message: Any): Unit

Definition Classes
Actor
def unsubscribe(channels: String*): Unit

Definition Classes
RedisSubscriberActor
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def write(byteString: ByteString): Unit

Definition Classes
RedisWorkerIO
def writing: Receive

Definition Classes
RedisSubscriberActor → RedisWorkerIO

Related Doc: package actors

class RedisSubscriberActorWithCallback extends RedisSubscriberActor

Instance Constructors

new RedisSubscriberActorWithCallback(address: InetSocketAddress, channels: Seq[String], patterns: Seq[String], messageCallback: (Message) ⇒ Unit, pmessageCallback: (PMessage) ⇒ Unit, authPassword: Option[String] = None, onConnectStatus: (Boolean) ⇒ Unit)

Type Members

type Receive = PartialFunction[Any, Unit]

Value Members

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]

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

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 onMessage(m: Message): Unit

def onPMessage(pm: PMessage): 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