class
KestrelHandler
extends AnyRef
Instance Constructors
-
new
KestrelHandler
(queues: QueueCollection, maxOpenReads: Int, clientDescription: () ⇒ String, sessionId: Int)
Abstract Value Members
-
def
addPendingRead
(key: String, xid: Int): Option[Long]
-
def
cancelAllPendingReads
(): Int
-
def
countPendingReads
(key: String): Int
Concrete Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
abortAnyOpenRead
(): Unit
-
def
asInstanceOf
[T0]
: T0
-
val
clientDescription
: () ⇒ String
-
def
clone
(): AnyRef
-
def
delete
(key: String): Unit
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
finish
(): Unit
-
val
finished
: AtomicBoolean
-
def
flush
(key: String): Unit
-
def
flushAllQueues
(): Unit
-
def
flushExpired
(key: String): Int
-
def
getClass
(): java.lang.Class[_]
-
def
getItem
(key: String, timeout: Option[Time], opening: Boolean, peeking: Boolean): Future[Option[QItem]]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
val
log
: Logger
-
val
maxOpenReads
: Int
-
def
monitorUntil
(key: String, timeLimit: Option[Time], maxItems: Int, opening: Boolean)(f: (Option[QItem], Option[Long]) ⇒ Unit): Unit
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
-
val
sessionId
: Int
-
def
setItem
(key: String, flags: Int, expiry: Option[Time], data: Array[Byte]): Boolean
-
def
shutdown
(): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
var
waitingFor
: Option[Future[Option[QItem]]]
Inherited from AnyRef
Inherited from Any
Common implementations of kestrel commands that don't depend on which protocol you're using.