Package org.apache.pekko.persistence.query

Class UpdatedDurableState<A>

java.lang.Object

org.apache.pekko.persistence.query.UpdatedDurableState<A>

Type Parameters:

A - the type of the value

All Implemented Interfaces:

DurableStateChange<A>

public final class UpdatedDurableState<A>
extends Object
implements DurableStateChange<A>

param: persistenceId The persistence id of the origin entity. param: revision The revision number from the origin entity. param: value The object value. param: offset The offset that can be used in next changes or currentChanges query. param: timestamp The time the state was stored, in milliseconds since midnight, January 1, 1970 UTC (same as System.currentTimeMillis).

Constructor Summary

Constructors

Constructor	Description
UpdatedDurableState(String persistenceId, long revision, A value, Offset offset, long timestamp)

Method Summary

Modifier and Type	Method	Description
Offset	offset()	The offset that can be used in next changes or currentChanges query.
String	persistenceId()	The persistence id of the origin entity.
long	revision()
long	timestamp()
static <A> scala.Option<scala.Tuple5<String,Object,A,Offset,Object>>	unapply(UpdatedDurableState<A> arg)
A	value()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UpdatedDurableState

public UpdatedDurableState(String persistenceId,
 long revision,
 A value,
 Offset offset,
 long timestamp)

Method Details

unapply

public static <A>
scala.Option<scala.Tuple5<String,Object,A,Offset,Object>> unapply(UpdatedDurableState<A> arg)

persistenceId

public String persistenceId()

Description copied from interface: DurableStateChange

The persistence id of the origin entity.

Specified by:

persistenceId in interface DurableStateChange<A>

revision

public long revision()

value

public A value()

offset

public Offset offset()

Description copied from interface: DurableStateChange

The offset that can be used in next changes or currentChanges query.

Specified by:

offset in interface DurableStateChange<A>

timestamp

public long timestamp()