akka.persistence.multidc

Class ReplicatedEventContext

java.lang.Object

akka.persistence.multidc.ReplicatedEventContext

All Implemented Interfaces:

EventContext

public final class ReplicatedEventContext
extends java.lang.Object
implements EventContext

Additional information about an event. The event was persisted by another data center.

param: originDc the event was persisted by this data center param: timestamp time when the event was persisted as returned by InternalReplicatedEntity.currentTimeMillis() or InternalReplicatedEntity.currentTimeMillis(), which is typically in epoch milliseconds, i.e. milliseconds since midnight, January 1, 1970 UTC. param: sequenceNr the sequence number of the event param: recoveryRunning true when the event is applied from replay when recovering the state at startup, false if it was persisted now param: concurrent The event was persisted with causal order (concurrent=false) to the previous event here, or an update occurred in both data centers before the events had been replicated to the other side (concurrent=true).

See Also:

InternalReplicatedEntity.replicatedEventHandler(akka.persistence.multidc.ReplicatedEventContext, State, Event), InternalReplicatedEntity.replicatedEventHandler(akka.persistence.multidc.ReplicatedEventContext, State, Event)

Constructor Summary

Constructors

Constructor and Description
ReplicatedEventContext(java.lang.String originDc, long timestamp, long sequenceNr, boolean recoveryRunning, boolean concurrent)

Method Summary

Modifier and Type	Method and Description
boolean	concurrent()
java.lang.String	originDc()
boolean	recoveryRunning() true when the event is applied from replay when recovering the state at startup, false if it was persisted now
long	sequenceNr() The sequence number of the event.
long	timestamp() Time when the event was persisted as returned by InternalReplicatedEntity.currentTimeMillis() or InternalReplicatedEntity.currentTimeMillis(), which is typically in epoch milliseconds, i.e.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedEventContext

public ReplicatedEventContext(java.lang.String originDc,
                              long timestamp,
                              long sequenceNr,
                              boolean recoveryRunning,
                              boolean concurrent)

Method Detail

concurrent

public boolean concurrent()

originDc

public java.lang.String originDc()

recoveryRunning

public boolean recoveryRunning()

Description copied from interface: EventContext

true when the event is applied from replay when recovering the state at startup, false if it was persisted now

Specified by:

recoveryRunning in interface EventContext

Returns:

(undocumented)

sequenceNr

public long sequenceNr()

Description copied from interface: EventContext

The sequence number of the event.

Specified by:

sequenceNr in interface EventContext

Returns:

(undocumented)

timestamp

public long timestamp()

Description copied from interface: EventContext

Time when the event was persisted as returned by InternalReplicatedEntity.currentTimeMillis() or InternalReplicatedEntity.currentTimeMillis(), which is typically in epoch milliseconds, i.e. milliseconds since midnight, January 1, 1970 UTC.

Specified by:

timestamp in interface EventContext

Returns:

(undocumented)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object