akka.actor.mailbox.filebased.filequeue

PersistentQueue

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 any2stringfmt
  3. by any2ArrowAssoc
  4. by any2Ensuring
  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: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

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

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

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

    Definition Classes
    AnyRef
  7. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  8. def add(value: Array[Byte]): Boolean

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

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

  10. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  11. def bytes: Long

  12. def clone(): AnyRef

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

    Close the queue's journal file.

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

  14. def configure(settings: FileBasedMailboxSettings): Unit

  15. def confirmRemove(xid: Int): Unit

  16. def currentAge: Long

  17. def destroyJournal(): Unit

  18. final def discardExpired(): Int

  19. final val discardOldWhenFull: OverlaySetting[Boolean]

  20. def dumpConfig(): Array[String]

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

  22. 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 any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  23. def ensuring(cond: (PersistentQueue) ⇒ Boolean): PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  24. 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 any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  25. def ensuring(cond: Boolean): PersistentQueue

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

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

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

  29. def finalize(): Unit

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

  31. def formatted(fmtstr: String): String

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

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

    Definition Classes
    AnyRef → Any
  34. def inReadBehind: Boolean

  35. def isClosed: Boolean

  36. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  37. def journalSize: Long

  38. final val keepJournal: OverlaySetting[Boolean]

  39. def length: Long

  40. final val maxAge: OverlaySetting[Int]

  41. final val maxItemSize: OverlaySetting[Long]

  42. final val maxItems: OverlaySetting[Int]

  43. final val maxJournalOverflow: OverlaySetting[Int]

  44. final val maxJournalSize: OverlaySetting[Long]

  45. final val maxJournalSizeAbsolute: OverlaySetting[Long]

  46. final val maxMemorySize: OverlaySetting[Long]

  47. final val maxSize: OverlaySetting[Long]

  48. def memoryBytes: Long

  49. def memoryLength: Long

  50. val name: String

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

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

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

    Definition Classes
    AnyRef
  54. def openTransactionCount: Int

  55. def openTransactionIds: List[Int]

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

  57. def pauseReads(): Unit

  58. def peek(): Option[QItem]

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

  59. def remove(): Option[QItem]

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

  60. 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)

  61. def replayJournal(): Unit

  62. def resumeReads(): Unit

  63. val settings: FileBasedMailboxSettings

  64. def setup(): Unit

  65. final val syncJournal: OverlaySetting[Boolean]

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

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

  68. def toString(): String

    Definition Classes
    AnyRef → Any
  69. def totalDiscarded: Long

  70. def totalExpired: Long

  71. def totalItems: Long

  72. 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.

  73. final def wait(): Unit

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

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

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

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

Shadowed Implicit Value Members

  1. val self: Any

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to StringAdd performed by method any2stringadd in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (persistentQueue: StringAdd).self
    Definition Classes
    StringAdd
  2. val self: Any

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to StringFormat performed by method any2stringfmt in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (persistentQueue: StringFormat).self
    Definition Classes
    StringFormat

Deprecated Value Members

  1. def x: PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to ArrowAssoc[PersistentQueue] performed by method any2ArrowAssoc in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (persistentQueue: ArrowAssoc[PersistentQueue]).x
    Definition Classes
    ArrowAssoc
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use leftOfArrow instead

  2. def x: PersistentQueue

    Implicit information
    This member is added by an implicit conversion from PersistentQueue to Ensuring[PersistentQueue] performed by method any2Ensuring in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (persistentQueue: Ensuring[PersistentQueue]).x
    Definition Classes
    Ensuring
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use resultOfEnsuring instead

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from PersistentQueue to StringAdd

Inherited by implicit conversion any2stringfmt from PersistentQueue to StringFormat

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

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

Ungrouped