class
PersistentQueue extends AnyRef
Instance Constructors
-
new
PersistentQueue(name: String, persistencePath: String, config: QueueConfig, timer: Timer, journalSyncScheduler: ScheduledExecutorService)
-
new
PersistentQueue(name: String, persistencePath: String, config: QueueConfig, timer: Timer, journalSyncScheduler: ScheduledExecutorService, queueLookup: Option[(String) ⇒ Option[PersistentQueue]])
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], expiry: Option[Time]): Boolean
-
def
add(value: Array[Byte]): Boolean
-
def
add(value: Array[Byte], expiry: Option[Time], xid: Option[Int], addTime: Time): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
bytes: Long
-
def
clone(): AnyRef
-
def
close(): Unit
-
-
def
confirmRemove(xid: Int): Unit
-
def
continue(xid: Int, value: Array[Byte], expiry: Option[Time]): Boolean
-
def
continue(xid: Int, value: Array[Byte]): Boolean
-
def
createTime: Long
-
def
currentAge: Duration
-
def
destroyJournal(): Unit
-
final
def
discardExpired(limit: Boolean = false): Int
-
def
dumpStats(): Array[(String, String)]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
evictWaiters(): Unit
-
-
def
finalize(): Unit
-
def
flush(): Unit
-
def
forceRewrite(): Unit
-
def
gauge(gaugeName: String, value: ⇒ Double): Unit
-
final
def
getClass(): java.lang.Class[_]
-
val
getItemsHit: AtomicLong
-
val
getItemsMiss: AtomicLong
-
def
hashCode(): Int
-
def
inReadBehind: Boolean
-
def
isClosed: Boolean
-
final
def
isInstanceOf[T0]: Boolean
-
def
isReadyForExpiration: Boolean
-
def
journalSize: Long
-
def
journalTotalSize: Long
-
def
length: Long
-
def
maxMemoryBytes: Long
-
def
memoryBytes: Long
-
def
memoryLength: Long
-
def
metric(metricName: String): Unit
-
val
name: String
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
openTransactionCount: Int
-
def
pauseReads(): Unit
-
def
peek(): Option[QItem]
-
val
putBytes: AtomicLong
-
val
putItems: AtomicLong
-
def
remove(): Option[QItem]
-
def
remove(transaction: Boolean): Option[QItem]
-
def
removeStats(): Unit
-
def
replayJournal(): Unit
-
def
resumeReads(): Unit
-
def
setup(): Unit
-
def
statNamed(statName: String): String
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
val
totalCanceledTransactions: Counter
-
val
totalDiscarded: Counter
-
val
totalExpired: Counter
-
val
totalFlushes: Counter
-
val
totalTransactions: Counter
-
def
unremove(xid: Int): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
final
def
waitPeek(deadline: Option[Time]): Future[Option[QItem]]
-
final
def
waitRemove(deadline: Option[Time], transaction: Boolean): Future[Option[QItem]]
-
def
waiterCount: Long
Inherited from AnyRef
Inherited from Any