class
PersistentQueue extends AnyRef
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
def
add(value: Array[Byte]): Boolean
-
def
add(value: Array[Byte], expiry: Long): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
bytes: Long
-
def
clone(): AnyRef
-
def
close(): Unit
-
-
def
confirmRemove(xid: Int): Unit
-
def
currentAge: Long
-
def
destroyJournal(): Unit
-
final
def
discardExpired(): Int
-
val
discardOldWhenFull: OverlaySetting[Boolean]
-
def
dumpConfig(): Array[String]
-
def
dumpStats(): Array[(String, String)]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
-
def
finalize(): Unit
-
def
flush(): Unit
-
final
def
getClass(): java.lang.Class[_]
-
def
hashCode(): Int
-
def
inReadBehind: Boolean
-
def
isClosed: Boolean
-
final
def
isInstanceOf[T0]: Boolean
-
def
journalSize: Long
-
-
def
length: Long
-
-
-
-
val
maxJournalOverflow: OverlaySetting[Int]
-
-
val
maxJournalSizeAbsolute: OverlaySetting[Long]
-
-
-
def
memoryBytes: Long
-
def
memoryLength: Long
-
val
name: String
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
openTransactionCount: Int
-
def
openTransactionIds: List[Int]
-
def
overlay[T](base: ⇒ T): OverlaySetting[T]
-
def
pauseReads(): Unit
-
def
peek(): Option[QItem]
-
def
remove(): Option[QItem]
-
def
remove(transaction: Boolean): Option[QItem]
-
def
replayJournal(): Unit
-
def
resumeReads(): Unit
-
-
def
setup(): Unit
-
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toList(): List[QItem]
-
def
toString(): String
-
def
totalDiscarded: Long
-
def
totalExpired: Long
-
def
totalItems: Long
-
def
unremove(xid: Int): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any