Package akka.persistence

Class PersistentImpl

java.lang.Object

akka.persistence.PersistentImpl

All Implemented Interfaces:

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

public final class PersistentImpl
extends java.lang.Object
implements PersistentRepr, NoSerializationVerificationNeeded, scala.Product, scala.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)

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)
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)
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()
boolean	deleted()	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.
boolean	equals(java.lang.Object obj)
int	hashCode()
java.lang.String	manifest()	Returns the persistent payload's manifest if available
java.lang.Object	payload()
java.lang.String	persistenceId()	Persistent id that journals a persistent message
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
ActorRef	sender()	Sender of this message.
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.Tuple8<java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,ActorRef,java.lang.String,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 manifest.
PersistentRepr	withPayload(java.lang.Object payload)	Creates a new persistent message with the specified payload.
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

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)

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)

unapply

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

payload

public java.lang.Object payload()

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

Returns:

(undocumented)

persistenceId

public java.lang.String persistenceId()

Description copied from interface: PersistentRepr

Persistent id that journals a persistent message

Specified by:

persistenceId in interface PersistentRepr

Returns:

(undocumented)

manifest

public java.lang.String manifest()

Description copied from interface: PersistentRepr

Returns the persistent payload's manifest if available

Specified by:

manifest in interface PersistentRepr

Returns:

(undocumented)

deleted

public boolean deleted()

Description copied from interface: PersistentRepr

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

Returns:

(undocumented)

sender

public ActorRef sender()

Description copied from interface: PersistentRepr

Sender of this message.

Specified by:

sender in interface PersistentRepr

Returns:

(undocumented)

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

Returns:

(undocumented)

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

Returns:

(undocumented)

withPayload

public PersistentRepr withPayload(java.lang.Object payload)

Description copied from interface: PersistentRepr

Creates a new persistent message with the specified payload.

Specified by:

withPayload in interface PersistentRepr

Parameters:

payload - (undocumented)

Returns:

(undocumented)

withManifest

public PersistentRepr withManifest(java.lang.String manifest)

Description copied from interface: PersistentRepr

Creates a new persistent message with the specified manifest.

Specified by:

withManifest in interface PersistentRepr

Parameters:

manifest - (undocumented)

Returns:

(undocumented)

withTimestamp

public PersistentRepr withTimestamp(long newTimestamp)

Specified by:

withTimestamp 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

Parameters:

sequenceNr - (undocumented)

persistenceId - (undocumented)

deleted - (undocumented)

sender - (undocumented)

writerUuid - (undocumented)

Returns:

(undocumented)

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

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)

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()

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object