trait BaseByteArrayJournalDao extends BaseDao[JournalRow] with JournalDaoWithUpdates with BaseJournalDaoWithReadMessages with H2Compat
The DefaultJournalDao contains all the knowledge to persist and load serialized journal entries
- Alphabetic
- By Inheritance
- BaseByteArrayJournalDao
- H2Compat
- BaseJournalDaoWithReadMessages
- JournalDaoWithUpdates
- JournalDao
- JournalDaoWithReadMessages
- BaseDao
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract val db: slick.jdbc.JdbcBackend.Database
- implicit abstract val ec: ExecutionContext
- Definition Classes
- BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
- abstract val journalConfig: JournalConfig
- implicit abstract val mat: Materializer
- Definition Classes
- BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
- abstract val profile: JdbcProfile
- Definition Classes
- BaseByteArrayJournalDao → H2Compat
- abstract val queries: JournalQueries
- abstract val serializer: FlowPersistentReprSerializer[JournalRow]
- Annotations
- @nowarn()
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asyncWriteMessages(messages: Seq[AtomicWrite]): Future[Seq[Try[Unit]]]
- Definition Classes
- BaseByteArrayJournalDao → JournalDao
- See also
akka.persistence.journal.AsyncWriteJournal.asyncWriteMessages(messages)
- def baseDaoConfig: BaseDaoConfig
- Definition Classes
- BaseByteArrayJournalDao → BaseDao
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def correctMaxForH2Driver(max: Long): Long
- Definition Classes
- H2Compat
- def delete(persistenceId: String, maxSequenceNr: Long): Future[Unit]
Deletes all persistent messages up to toSequenceNr (inclusive) for the persistenceId
Deletes all persistent messages up to toSequenceNr (inclusive) for the persistenceId
- Definition Classes
- BaseByteArrayJournalDao → JournalDao
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def highestSequenceNr(persistenceId: String, fromSequenceNr: Long): Future[Long]
Returns the highest sequence number for the events that are stored for that
persistenceId.Returns the highest sequence number for the events that are stored for that
persistenceId. When no events are found for thepersistenceId, 0L will be the highest sequence number- Definition Classes
- BaseByteArrayJournalDao → JournalDao
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val logger: Logger
- def messages(persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long, max: Long): Source[Try[(PersistentRepr, Long)], NotUsed]
Returns a Source of PersistentRepr and ordering number for a certain persistenceId.
Returns a Source of PersistentRepr and ordering number for a certain persistenceId. It includes the events with sequenceNr between
fromSequenceNr(inclusive) andtoSequenceNr(inclusive).- Definition Classes
- BaseByteArrayJournalDao → JournalDaoWithReadMessages
- def messagesWithBatch(persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long, batchSize: Int, refreshInterval: Option[(FiniteDuration, Scheduler)]): Source[Try[(PersistentRepr, Long)], NotUsed]
Returns a Source of PersistentRepr and ordering number for a certain persistenceId.
Returns a Source of PersistentRepr and ordering number for a certain persistenceId. It includes the events with sequenceNr between
fromSequenceNr(inclusive) andtoSequenceNr(inclusive).- Definition Classes
- BaseJournalDaoWithReadMessages → JournalDaoWithReadMessages
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def queueWriteJournalRows(xs: Seq[JournalRow]): Future[Unit]
- Definition Classes
- BaseDao
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def update(persistenceId: String, sequenceNr: Long, payload: AnyRef): Future[Done]
Update (!) an existing event with the passed in data.
Update (!) an existing event with the passed in data.
- Definition Classes
- BaseByteArrayJournalDao → JournalDaoWithUpdates
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def writeJournalRows(xs: Seq[JournalRow]): Future[Unit]
- Definition Classes
- BaseByteArrayJournalDao → BaseDao
- val writeQueue: SourceQueueWithComplete[(Promise[Unit], Seq[JournalRow])]
- Definition Classes
- BaseDao
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)