akka.actor.mailbox.filebased.filequeue

PersistentQueue

class PersistentQueue extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. PersistentQueue
  2. AnyRef
  3. Any
  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. final def ==(arg0: AnyRef): Boolean

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

    Definition Classes
    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. final def eq(arg0: AnyRef): Boolean

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

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

  23. def finalize(): Unit

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

  25. final def getClass(): Class[_]

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

    Definition Classes
    AnyRef → Any
  27. def inReadBehind: Boolean

  28. def isClosed: Boolean

  29. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  30. def journalSize: Long

  31. final val keepJournal: OverlaySetting[Boolean]

  32. def length: Long

  33. final val maxAge: OverlaySetting[Int]

  34. final val maxItemSize: OverlaySetting[Long]

  35. final val maxItems: OverlaySetting[Int]

  36. final val maxJournalOverflow: OverlaySetting[Int]

  37. final val maxJournalSize: OverlaySetting[Long]

  38. final val maxJournalSizeAbsolute: OverlaySetting[Long]

  39. final val maxMemorySize: OverlaySetting[Long]

  40. final val maxSize: OverlaySetting[Long]

  41. def memoryBytes: Long

  42. def memoryLength: Long

  43. val name: String

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

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

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

    Definition Classes
    AnyRef
  47. def openTransactionCount: Int

  48. def openTransactionIds: List[Int]

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

  50. def pauseReads(): Unit

  51. def peek(): Option[QItem]

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

  52. def remove(): Option[QItem]

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

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

  54. def replayJournal(): Unit

  55. def resumeReads(): Unit

  56. val settings: FileBasedMailboxSettings

  57. def setup(): Unit

  58. final val syncJournal: OverlaySetting[Boolean]

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

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

  61. def toString(): String

    Definition Classes
    AnyRef → Any
  62. def totalDiscarded: Long

  63. def totalExpired: Long

  64. def totalItems: Long

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

  66. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any

Ungrouped