Package akka.persistence

Class PersistentImpl

java.lang.Object

akka.persistence.PersistentImpl

All Implemented Interfaces:

NoSerializationVerificationNeeded, PersistentRepr, Message, java.io.Serializable, scala.Equals, scala.Product

public final class PersistentImpl
extends java.lang.Object
implements PersistentRepr, NoSerializationVerificationNeeded, scala.Product, java.io.Serializable

INTERNAL API.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
PersistentImpl(java.lang.Object payload, long sequenceNr, java.lang.String persistenceId, java.lang.String manifest, boolean deleted, ActorRef sender, java.lang.String writerUuid, long timestamp, scala.Option<java.lang.Object> metadata)

Method Summary

Modifier and Type	Method	Description
static PersistentImpl	apply(java.lang.Object payload, long sequenceNr, java.lang.String persistenceId, java.lang.String manifest, boolean deleted, ActorRef sender, java.lang.String writerUuid, long timestamp, scala.Option<java.lang.Object> metadata)
boolean	canEqual(java.lang.Object x$1)
PersistentImpl	copy(java.lang.Object payload, long sequenceNr, java.lang.String persistenceId, java.lang.String manifest, boolean deleted, ActorRef sender, java.lang.String writerUuid, long timestamp, scala.Option<java.lang.Object> metadata)
java.lang.Object	copy$default$1()
long	copy$default$2()
java.lang.String	copy$default$3()
java.lang.String	copy$default$4()
boolean	copy$default$5()
ActorRef	copy$default$6()
java.lang.String	copy$default$7()
long	copy$default$8()
scala.Option<java.lang.Object>	copy$default$9()
boolean	deleted()	Not used, can always be false.
boolean	equals(java.lang.Object obj)
int	hashCode()
java.lang.String	manifest()	Returns the event adapter manifest for the persistent payload (event) if available May be "" if event adapter manifest is not used.
scala.Option<java.lang.Object>	metadata()
java.lang.Object	payload()	This persistent message's payload (the event).
java.lang.String	persistenceId()	Persistent id that journals a persistent message
int	productArity()
java.lang.Object	productElement(int x$1)
java.lang.String	productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
ActorRef	sender()	Not used, can be null
long	sequenceNr()	This persistent message's sequence number.
long	timestamp()	The timestamp is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same as System.currentTimeMillis).
java.lang.String	toString()
static scala.Option<scala.Tuple9<java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,ActorRef,java.lang.String,java.lang.Object,scala.Option<java.lang.Object>>>	unapply(PersistentImpl x$0)
PersistentImpl	update(long sequenceNr, java.lang.String persistenceId, boolean deleted, ActorRef sender, java.lang.String writerUuid)	Creates a new copy of this PersistentRepr.
PersistentRepr	withManifest(java.lang.String manifest)	Creates a new persistent message with the specified event adapter manifest.
PersistentRepr	withMetadata(java.lang.Object metadata)
PersistentRepr	withPayload(java.lang.Object payload)	Creates a new persistent message with the specified payload (event).
PersistentRepr	withTimestamp(long newTimestamp)
java.lang.String	writerUuid()	Unique identifier of the writing persistent actor.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.persistence.PersistentRepr

update$default$1, update$default$2, update$default$3, update$default$4, update$default$5

Methods inherited from interface scala.Product

productElementNames

Constructor Detail

PersistentImpl

public PersistentImpl(java.lang.Object payload,
                      long sequenceNr,
                      java.lang.String persistenceId,
                      java.lang.String manifest,
                      boolean deleted,
                      ActorRef sender,
                      java.lang.String writerUuid,
                      long timestamp,
                      scala.Option<java.lang.Object> metadata)

Method Detail

apply

public static PersistentImpl apply(java.lang.Object payload,
                                   long sequenceNr,
                                   java.lang.String persistenceId,
                                   java.lang.String manifest,
                                   boolean deleted,
                                   ActorRef sender,
                                   java.lang.String writerUuid,
                                   long timestamp,
                                   scala.Option<java.lang.Object> metadata)

unapply

public static scala.Option<scala.Tuple9<java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,ActorRef,java.lang.String,java.lang.Object,scala.Option<java.lang.Object>>> unapply(PersistentImpl x$0)

payload

public java.lang.Object payload()

Description copied from interface: PersistentRepr

This persistent message's payload (the event).

Specified by:

payload in interface PersistentRepr

sequenceNr

public long sequenceNr()

Description copied from interface: PersistentRepr

This persistent message's sequence number.

Specified by:

sequenceNr in interface PersistentRepr

persistenceId

public java.lang.String persistenceId()

Description copied from interface: PersistentRepr

Persistent id that journals a persistent message

Specified by:

persistenceId in interface PersistentRepr

manifest

public java.lang.String manifest()

Description copied from interface: PersistentRepr

Returns the event adapter manifest for the persistent payload (event) if available May be "" if event adapter manifest is not used. Note that this is not the same as the manifest of the serialized representation of the payload.

Specified by:

manifest in interface PersistentRepr

deleted

public boolean deleted()

Description copied from interface: PersistentRepr

Not used, can always be false.

Not used in new records stored with Akka v2.4, but old records from v2.3 may have this as true if it was a non-permanent delete.

Specified by:

deleted in interface PersistentRepr

sender

public ActorRef sender()

Description copied from interface: PersistentRepr

Not used, can be null

Specified by:

sender in interface PersistentRepr

writerUuid

public java.lang.String writerUuid()

Description copied from interface: PersistentRepr

Unique identifier of the writing persistent actor. Used to detect anomalies with overlapping writes from multiple persistent actors, which can result in inconsistent replays.

Specified by:

writerUuid in interface PersistentRepr

timestamp

public long timestamp()

Description copied from interface: PersistentRepr

The timestamp is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same as System.currentTimeMillis).

Value 0 is used if undefined.

Specified by:

timestamp in interface PersistentRepr

metadata

public scala.Option<java.lang.Object> metadata()

Specified by:

metadata in interface PersistentRepr

withPayload

public PersistentRepr withPayload(java.lang.Object payload)

Description copied from interface: PersistentRepr

Creates a new persistent message with the specified payload (event).

Specified by:

withPayload in interface PersistentRepr

withManifest

public PersistentRepr withManifest(java.lang.String manifest)

Description copied from interface: PersistentRepr

Creates a new persistent message with the specified event adapter manifest.

Specified by:

withManifest in interface PersistentRepr

withTimestamp

public PersistentRepr withTimestamp(long newTimestamp)

Specified by:

withTimestamp in interface PersistentRepr

withMetadata

public PersistentRepr withMetadata(java.lang.Object metadata)

Specified by:

withMetadata in interface PersistentRepr

update

public PersistentImpl update(long sequenceNr,
                             java.lang.String persistenceId,
                             boolean deleted,
                             ActorRef sender,
                             java.lang.String writerUuid)

Description copied from interface: PersistentRepr

Creates a new copy of this PersistentRepr.

Specified by:

update in interface PersistentRepr

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

copy

public PersistentImpl copy(java.lang.Object payload,
                           long sequenceNr,
                           java.lang.String persistenceId,
                           java.lang.String manifest,
                           boolean deleted,
                           ActorRef sender,
                           java.lang.String writerUuid,
                           long timestamp,
                           scala.Option<java.lang.Object> metadata)

copy$default$1

public java.lang.Object copy$default$1()

copy$default$2

public long copy$default$2()

copy$default$3

public java.lang.String copy$default$3()

copy$default$4

public java.lang.String copy$default$4()

copy$default$5

public boolean copy$default$5()

copy$default$6

public ActorRef copy$default$6()

copy$default$7

public java.lang.String copy$default$7()

copy$default$8

public long copy$default$8()

copy$default$9

public scala.Option<java.lang.Object> copy$default$9()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public java.lang.String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product