|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.Persistent akka.persistence.PersistentImpl
public class PersistentImpl
INTERNAL API.
Constructor Summary | |
---|---|
PersistentImpl(java.lang.Object payload,
long sequenceNr,
java.lang.String persistenceId,
boolean deleted,
scala.collection.immutable.Seq<java.lang.String> confirms,
ActorRef sender)
|
Method Summary | |
---|---|
boolean |
confirmable()
true only if this message has been delivered by a channel. |
Delivered |
confirmMessage()
Delivery confirmation message. |
scala.collection.immutable.Seq<java.lang.String> |
confirms()
Channel ids of delivery confirmations that are available for this message. |
ActorRef |
confirmTarget()
Delivery confirmation message. |
boolean |
deleted()
true if this message is marked as deleted. |
java.lang.Object |
payload()
This persistent message's payload. |
java.lang.String |
persistenceId()
Persistent id that journals a persistent message |
PersistentImpl |
prepareWrite(ActorRef sender)
INTERNAL API. |
java.lang.String |
processorId()
Persistent id that journals a persistent message |
int |
redeliveries()
Number of redeliveries. |
ActorRef |
sender()
Sender of this message. |
long |
sequenceNr()
This persistent message's sequence number. |
PersistentImpl |
update(long sequenceNr,
java.lang.String persistenceId,
boolean deleted,
int redeliveries,
scala.collection.immutable.Seq<java.lang.String> confirms,
Delivered confirmMessage,
ActorRef confirmTarget,
ActorRef sender)
Creates a new copy of this PersistentRepr . |
Persistent |
withPayload(java.lang.Object payload)
Creates a new persistent message with the specified payload . |
Methods inherited from class akka.persistence.Persistent |
---|
apply, create, create, unapply |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.persistence.PersistentRepr |
---|
getConfirms, prepareWrite |
Methods inherited from interface scala.Product |
---|
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
---|
canEqual, equals |
Constructor Detail |
---|
public PersistentImpl(java.lang.Object payload, long sequenceNr, java.lang.String persistenceId, boolean deleted, scala.collection.immutable.Seq<java.lang.String> confirms, ActorRef sender)
Method Detail |
---|
public java.lang.Object payload()
Persistent
payload
in interface PersistentRepr
payload
in interface Resequenceable
payload
in class Persistent
public long sequenceNr()
Persistent
sequenceNr
in interface PersistentId
sequenceNr
in class Persistent
public java.lang.String persistenceId()
PersistentId
persistenceId
in interface PersistentId
public boolean deleted()
PersistentRepr
true
if this message is marked as deleted.
deleted
in interface PersistentRepr
public scala.collection.immutable.Seq<java.lang.String> confirms()
PersistentRepr
confirms
in interface PersistentRepr
public ActorRef sender()
PersistentRepr
sender
in interface PersistentRepr
sender
in interface Resequenceable
public Persistent withPayload(java.lang.Object payload)
Persistent
payload
.
withPayload
in class Persistent
payload
- (undocumented)
public PersistentImpl prepareWrite(ActorRef sender)
PersistentRepr
prepareWrite
in interface PersistentRepr
sender
- (undocumented)
public PersistentImpl update(long sequenceNr, java.lang.String persistenceId, boolean deleted, int redeliveries, scala.collection.immutable.Seq<java.lang.String> confirms, Delivered confirmMessage, ActorRef confirmTarget, ActorRef sender)
PersistentRepr
PersistentRepr
.
update
in interface PersistentRepr
sequenceNr
- (undocumented)persistenceId
- (undocumented)deleted
- (undocumented)redeliveries
- (undocumented)confirms
- (undocumented)confirmMessage
- (undocumented)confirmTarget
- (undocumented)sender
- (undocumented)
public int redeliveries()
PersistentRepr
Channel
or PersistentChannel
.
redeliveries
in interface PersistentRepr
public boolean confirmable()
PersistentRepr
true
only if this message has been delivered by a channel.
confirmable
in interface PersistentRepr
public Delivered confirmMessage()
PersistentRepr
confirmMessage
in interface PersistentRepr
public ActorRef confirmTarget()
PersistentRepr
confirmTarget
in interface PersistentRepr
public java.lang.String processorId()
PersistentId
processorId
in interface PersistentId
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |