akka.persistence
Class PersistentImpl

java.lang.Object
  akka.persistence.Persistent
      akka.persistence.PersistentImpl

All Implemented Interfaces:

PersistentId, PersistentRepr, Resequenceable, Message, java.io.Serializable, scala.Equals, scala.Product

public class PersistentImpl
extends Persistent
implements PersistentRepr, scala.Product, scala.Serializable

INTERNAL API.

See Also:

Serialized Form

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

PersistentImpl

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

payload

public java.lang.Object payload()

Description copied from class: Persistent

This persistent message's payload.

Specified by:

payload in interface PersistentRepr

Specified by:

payload in interface Resequenceable

Specified by:

payload in class Persistent

Returns:

(undocumented)

sequenceNr

public long sequenceNr()

Description copied from class: Persistent

This persistent message's sequence number.

Specified by:

sequenceNr in interface PersistentId

Specified by:

sequenceNr in class Persistent

Returns:

(undocumented)

persistenceId

public java.lang.String persistenceId()

Description copied from interface: PersistentId

Persistent id that journals a persistent message

Specified by:

persistenceId in interface PersistentId

Returns:

(undocumented)

deleted

public boolean deleted()

Description copied from interface: PersistentRepr

true if this message is marked as deleted.

Specified by:

deleted in interface PersistentRepr

Returns:

(undocumented)

confirms

public scala.collection.immutable.Seq<java.lang.String> confirms()

Description copied from interface: PersistentRepr

Channel ids of delivery confirmations that are available for this message. Only non-empty for replayed messages.

Specified by:

confirms in interface PersistentRepr

Returns:

(undocumented)

sender

public ActorRef sender()

Description copied from interface: PersistentRepr

Sender of this message.

Specified by:

sender in interface PersistentRepr

Specified by:

sender in interface Resequenceable

Returns:

(undocumented)

withPayload

public Persistent withPayload(java.lang.Object payload)

Description copied from class: Persistent

Creates a new persistent message with the specified payload.

Specified by:

withPayload in class Persistent

Parameters:

payload - (undocumented)

Returns:

(undocumented)

prepareWrite

public PersistentImpl prepareWrite(ActorRef sender)

Description copied from interface: PersistentRepr

INTERNAL API.

Specified by:

prepareWrite in interface PersistentRepr

Parameters:

sender - (undocumented)

Returns:

(undocumented)

update

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)

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)

redeliveries - (undocumented)

confirms - (undocumented)

confirmMessage - (undocumented)

confirmTarget - (undocumented)

sender - (undocumented)

Returns:

(undocumented)

redeliveries

public int redeliveries()

Description copied from interface: PersistentRepr

Number of redeliveries. Only greater than zero if message has been redelivered by a Channel or PersistentChannel.

Specified by:

redeliveries in interface PersistentRepr

Returns:

(undocumented)

confirmable

public boolean confirmable()

Description copied from interface: PersistentRepr

true only if this message has been delivered by a channel.

Specified by:

confirmable in interface PersistentRepr

Returns:

(undocumented)

confirmMessage

public Delivered confirmMessage()

Description copied from interface: PersistentRepr

Delivery confirmation message.

Specified by:

confirmMessage in interface PersistentRepr

Returns:

(undocumented)

confirmTarget

public ActorRef confirmTarget()

Description copied from interface: PersistentRepr

Delivery confirmation message.

Specified by:

confirmTarget in interface PersistentRepr

Returns:

(undocumented)

processorId

public java.lang.String processorId()

Description copied from interface: PersistentId

Persistent id that journals a persistent message

Specified by:

processorId in interface PersistentId

Returns:

(undocumented)