akka.actor.mailbox.filebased.filequeue

PersistentQueue

Related Docs: object PersistentQueue | package filequeue

class PersistentQueue extends AnyRef

Annotations
@deprecated
Deprecated

(Since version 2.3) durable mailboxes are superseded by akka-persistence

Source
PersistentQueue.scala
Linear Supertypes
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. PersistentQueue
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PersistentQueue(persistencePath: String, name: String, settings: FileBasedMailboxSettings, log: LoggingAdapter)

Value Members

  1. final def !=(arg0: Any): Boolean

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

    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to any2stringadd[PersistentQueue] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (PersistentQueue, B)

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to ArrowAssoc[PersistentQueue] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  6. def add(value: Array[Byte]): Boolean

  7. def add(value: Array[Byte], expiry: Long): Boolean

    Add a value to the end of the queue, transactionally.

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  9. def bytes: Long

  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. def close(): Unit

    Close the queue's journal file.

    Close the queue's journal file. Not safe to call on an active queue.

  12. def configure(settings: FileBasedMailboxSettings): Unit

  13. def confirmRemove(xid: Int): Unit

  14. def currentAge: Long

  15. def destroyJournal(): Unit

  16. final def discardExpired(): Int

  17. final val discardOldWhenFull: OverlaySetting[Boolean]

  18. def dumpConfig(): Array[String]

  19. def dumpStats(): Array[(String, String)]

  20. def ensuring(cond: (PersistentQueue) ⇒ Boolean, msg: ⇒ Any): PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. def ensuring(cond: (PersistentQueue) ⇒ Boolean): PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  22. def ensuring(cond: Boolean, msg: ⇒ Any): PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  23. def ensuring(cond: Boolean): PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  24. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  26. final val expiredQueue: OverlaySetting[Option[PersistentQueue]]

  27. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  28. def flush(): Unit

  29. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to StringFormat[PersistentQueue] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  30. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  31. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  32. def inReadBehind: Boolean

  33. def isClosed: Boolean

  34. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  35. def journalSize: Long

  36. final val keepJournal: OverlaySetting[Boolean]

  37. def length: Long

  38. final val maxAge: OverlaySetting[Int]

  39. final val maxItemSize: OverlaySetting[Long]

  40. final val maxItems: OverlaySetting[Int]

  41. final val maxJournalOverflow: OverlaySetting[Int]

  42. final val maxJournalSize: OverlaySetting[Long]

  43. final val maxJournalSizeAbsolute: OverlaySetting[Long]

  44. final val maxMemorySize: OverlaySetting[Long]

  45. final val maxSize: OverlaySetting[Long]

  46. def memoryBytes: Long

  47. def memoryLength: Long

  48. val name: String

  49. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  50. final def notify(): Unit

    Definition Classes
    AnyRef
  51. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  52. def openTransactionCount: Int

  53. def openTransactionIds: List[Int]

  54. def overlay[T](base: ⇒ T): OverlaySetting[T]

  55. def pauseReads(): Unit

  56. def peek(): Option[QItem]

    Peek at the head item in the queue, if there is one.

  57. def remove(): Option[QItem]

    Remove and return an item from the queue, if there is one.

  58. def remove(transaction: Boolean): Option[QItem]

    Remove and return an item from the queue, if there is one.

    Remove and return an item from the queue, if there is one.

    transaction

    true if this should be considered the first part of a transaction, to be committed or rolled back (put back at the head of the queue)

  59. def replayJournal(): Unit

  60. def resumeReads(): Unit

  61. val settings: FileBasedMailboxSettings

  62. def setup(): Unit

  63. final val syncJournal: OverlaySetting[Boolean]

  64. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  65. def toList(): List[QItem]

  66. def toString(): String

    Definition Classes
    AnyRef → Any
  67. def totalDiscarded: Long

  68. def totalExpired: Long

  69. def totalItems: Long

  70. def unremove(xid: Int): Unit

    Return a transactionally-removed item to the queue.

    Return a transactionally-removed item to the queue. This is a rolled- back transaction.

  71. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  74. def [B](y: B): (PersistentQueue, B)

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to ArrowAssoc[PersistentQueue] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from PersistentQueue to any2stringadd[PersistentQueue]

Inherited by implicit conversion StringFormat from PersistentQueue to StringFormat[PersistentQueue]

Inherited by implicit conversion Ensuring from PersistentQueue to Ensuring[PersistentQueue]

Inherited by implicit conversion ArrowAssoc from PersistentQueue to ArrowAssoc[PersistentQueue]

Ungrouped