Package akka.persistence.state.javadsl

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 Scala API see DurableStateUpdateWithChangeEventStore.

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletionStage<Done>	deleteObject(java.lang.String persistenceId, long revision, java.lang.Object changeEvent)
java.util.concurrent.CompletionStage<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.javadsl.DurableStateStore

getObject

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

deleteObject, deleteObject, upsertObject

Method Detail

deleteObject

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

upsertObject

java.util.concurrent.CompletionStage<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.