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
All Methods Static Methods Instance Methods Concrete Methods 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 astrue
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 availablejava.lang.Object
payload()
java.lang.String
persistenceId()
Persistent id that journals a persistent messageint
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()
Thetimestamp
is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same asSystem.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 thisPersistentRepr
.PersistentRepr
withManifest(java.lang.String manifest)
Creates a new persistent message with the specifiedmanifest
.PersistentRepr
withPayload(java.lang.Object payload)
Creates a new persistent message with the specifiedpayload
.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 interfacePersistentRepr
-
sequenceNr
public long sequenceNr()
Description copied from interface:PersistentRepr
This persistent message's sequence number.- Specified by:
sequenceNr
in interfacePersistentRepr
- Returns:
- (undocumented)
-
persistenceId
public java.lang.String persistenceId()
Description copied from interface:PersistentRepr
Persistent id that journals a persistent message- Specified by:
persistenceId
in interfacePersistentRepr
- 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 interfacePersistentRepr
- 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 astrue
if it was a non-permanent delete.- Specified by:
deleted
in interfacePersistentRepr
- Returns:
- (undocumented)
-
sender
public ActorRef sender()
Description copied from interface:PersistentRepr
Sender of this message.- Specified by:
sender
in interfacePersistentRepr
- 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 interfacePersistentRepr
- Returns:
- (undocumented)
-
timestamp
public long timestamp()
Description copied from interface:PersistentRepr
Thetimestamp
is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same asSystem.currentTimeMillis
).Value
0
is used if undefined.- Specified by:
timestamp
in interfacePersistentRepr
- Returns:
- (undocumented)
-
withPayload
public PersistentRepr withPayload(java.lang.Object payload)
Description copied from interface:PersistentRepr
Creates a new persistent message with the specifiedpayload
.- Specified by:
withPayload
in interfacePersistentRepr
- 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 specifiedmanifest
.- Specified by:
withManifest
in interfacePersistentRepr
- Parameters:
manifest
- (undocumented)- Returns:
- (undocumented)
-
withTimestamp
public PersistentRepr withTimestamp(long newTimestamp)
- Specified by:
withTimestamp
in interfacePersistentRepr
-
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 thisPersistentRepr
.- Specified by:
update
in interfacePersistentRepr
- Parameters:
sequenceNr
- (undocumented)persistenceId
- (undocumented)deleted
- (undocumented)sender
- (undocumented)writerUuid
- (undocumented)- Returns:
- (undocumented)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.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 interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-