Package akka.persistence.state.scaladsl

Interface DurableStateUpdateWithChangeEventStore<A>

All Superinterfaces:

DurableStateStore<A>, DurableStateUpdateStore<A>

All Known Implementing Classes:

PersistenceTestKitDurableStateStore

public interface DurableStateUpdateWithChangeEventStore<A>
extends DurableStateUpdateStore<A>

API May Change: API for updating durable state objects and storing additional change event.

For Java API see DurableStateUpdateWithChangeEventStore.

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Done>	deleteObject(java.lang.String persistenceId, long revision, java.lang.Object changeEvent)
scala.concurrent.Future<Done>	upsertObject(java.lang.String persistenceId, long revision, A value, java.lang.String tag, java.lang.Object changeEvent)	The changeEvent is written to the event journal.

Methods inherited from interface akka.persistence.state.scaladsl.DurableStateStore

getObject

Methods inherited from interface akka.persistence.state.scaladsl.DurableStateUpdateStore

deleteObject, deleteObject, upsertObject

Method Detail

deleteObject

scala.concurrent.Future<Done> deleteObject(java.lang.String persistenceId,
                                           long revision,
                                           java.lang.Object changeEvent)

upsertObject

scala.concurrent.Future<Done> upsertObject(java.lang.String persistenceId,
                                           long revision,
                                           A value,
                                           java.lang.String tag,
                                           java.lang.Object changeEvent)

The changeEvent is written to the event journal. Same persistenceId is used in the journal and the revision is used as sequenceNr.

Parameters:

revision - sequence number for optimistic locking. starts at 1.