scredis
.
io
ListenerActor
class
ListenerActor
extends
Actor
with
LazyLogging
Linear Supertypes
LazyLogging
,
Logging
,
Actor
,
AnyRef
,
Any
Known Subclasses
SubscriberListenerActor
Ordering
Alphabetic
By inheritance
Inherited
ListenerActor
LazyLogging
Logging
Actor
AnyRef
Any
Hide All
Show all
Learn more about member selection
Visibility
Public
All
Instance Constructors
new
ListenerActor
(
host:
String
,
port:
Int
,
passwordOpt:
Option
[
String
]
,
database:
Int
,
nameOpt:
Option
[
String
]
,
decodersCount:
Int
,
receiveTimeoutOpt:
Option
[
FiniteDuration
]
,
connectTimeout:
FiniteDuration
,
maxWriteBatchSize:
Int
,
tcpSendBufferSizeHint:
Int
,
tcpReceiveBufferSizeHint:
Int
,
akkaIODispatcherPath:
String
,
akkaDecoderDispatcherPath:
String
)
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
def
always
:
Receive
Attributes
protected
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
def
awaitingDecodersShutdown
:
Receive
def
become
(
state:
Receive
)
:
Unit
Attributes
protected
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
def
connecting
:
Receive
implicit
val
context
:
ActorContext
Definition Classes
Actor
var
database
:
Int
var
decoders
:
Router
Attributes
protected
var
decodersCount
:
Int
def
doSend
(
request:
Request
[_]
)
:
Unit
Attributes
protected
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
equals
(
arg0:
Any
)
:
Boolean
Definition Classes
AnyRef → Any
def
fail
:
Receive
Attributes
protected
def
failAllQueuedRequests
(
throwable:
Throwable
)
:
Unit
Attributes
protected
def
failAllSentRequests
(
throwable:
Throwable
)
:
Unit
Attributes
protected
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
handleData
(
data:
ByteString
,
responsesCount:
Int
)
:
Unit
Attributes
protected
def
handleReceiveTimeout
()
:
Unit
Attributes
protected
def
hashCode
()
:
Int
Definition Classes
AnyRef → Any
def
initialized
:
Receive
def
initializing
:
Receive
var
ioActor
:
ActorRef
Attributes
protected
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
lazy val
logger
:
Logger
Attributes
protected
Definition Classes
LazyLogging → Logging
var
nameOpt
:
Option
[
String
]
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
def
onConnect
()
:
Unit
Attributes
protected
def
onInitialized
()
:
Unit
Attributes
protected
var
passwordOpt
:
Option
[
String
]
def
postRestart
(
reason:
Throwable
)
:
Unit
Definition Classes
Actor
Annotations
@throws
(
classOf[java.lang.Exception]
)
def
postStop
()
:
Unit
Definition Classes
Actor
Annotations
@throws
(
classOf[java.lang.Exception]
)
def
preRestart
(
reason:
Throwable
,
message:
Option
[
Any
]
)
:
Unit
Definition Classes
Actor
Annotations
@throws
(
classOf[java.lang.Exception]
)
def
preStart
()
:
Unit
Definition Classes
ListenerActor
→ Actor
def
queue
:
Receive
Attributes
protected
val
queuedRequests
:
LinkedList
[
Request
[_]]
Attributes
protected
def
receive
:
Receive
Definition Classes
ListenerActor
→ Actor
def
receive
(
data:
ByteString
)
:
Int
Attributes
protected
def
reconnect
()
:
Unit
Attributes
protected
def
reconnecting
:
Receive
val
requests
:
LinkedList
[
Request
[_]]
Attributes
protected
implicit final
val
self
:
ActorRef
Definition Classes
Actor
def
send
:
Receive
Attributes
protected
def
send
(
requests:
Request
[_]*
)
:
Unit
Attributes
protected
def
sendAllQueuedRequests
()
:
Unit
Attributes
protected
final
def
sender
()
:
ActorRef
Definition Classes
Actor
def
shutdown
()
:
Unit
Attributes
protected
def
shuttingDown
:
Receive
val
supervisorStrategy
:
OneForOneStrategy
Definition Classes
ListenerActor
→ Actor
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
def
toString
()
:
String
Definition Classes
AnyRef → Any
def
unhandled
:
Receive
Attributes
protected
def
unhandled
(
message:
Any
)
:
Unit
Definition Classes
Actor
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
(
...
)
Inherited from
LazyLogging
Inherited from
Logging
Inherited from
Actor
Inherited from
AnyRef
Inherited from
Any
Ungrouped