akka.persistence
Class ConfirmablePersistentImpl

java.lang.Object
  akka.persistence.Persistent
      akka.persistence.ConfirmablePersistent
          akka.persistence.ConfirmablePersistentImpl

All Implemented Interfaces:

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

public class ConfirmablePersistentImpl
extends ConfirmablePersistent
implements PersistentRepr, scala.Product, scala.Serializable

INTERNAL API.

See Also:

Serialized Form

Constructor Summary

ConfirmablePersistentImpl(java.lang.Object payload, long sequenceNr, java.lang.String persistenceId, boolean deleted, int redeliveries, scala.collection.immutable.Seq<java.lang.String> confirms, Delivered confirmMessage, ActorRef confirmTarget, ActorRef sender)

Method Summary

static ConfirmablePersistentImpl	apply(PersistentRepr persistent, Delivered confirmMessage, ActorRef confirmTarget)
void	confirm() Called by Channel and PersistentChannel destinations to confirm the receipt of a persistent message.
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
ConfirmablePersistentImpl	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.
ConfirmablePersistentImpl	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.
ConfirmablePersistent	withPayload(java.lang.Object payload) Creates a new persistent message with the specified payload.

Methods inherited from class akka.persistence.ConfirmablePersistent

unapply

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

ConfirmablePersistentImpl

public ConfirmablePersistentImpl(java.lang.Object payload,
                                 long sequenceNr,
                                 java.lang.String persistenceId,
                                 boolean deleted,
                                 int redeliveries,
                                 scala.collection.immutable.Seq<java.lang.String> confirms,
                                 Delivered confirmMessage,
                                 ActorRef confirmTarget,
                                 ActorRef sender)

Method Detail

apply

public static ConfirmablePersistentImpl apply(PersistentRepr persistent,
                                              Delivered confirmMessage,
                                              ActorRef confirmTarget)

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)

redeliveries

public int redeliveries()

Description copied from class: ConfirmablePersistent

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

Specified by:

redeliveries in interface PersistentRepr

Specified by:

redeliveries in class ConfirmablePersistent

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)

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)

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

confirm

public void confirm()

Description copied from class: ConfirmablePersistent

Called by Channel and PersistentChannel destinations to confirm the receipt of a persistent message.

Specified by:

confirm in class ConfirmablePersistent

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)

prepareWrite

public ConfirmablePersistentImpl prepareWrite(ActorRef sender)

Description copied from interface: PersistentRepr

INTERNAL API.

Specified by:

prepareWrite in interface PersistentRepr

Parameters:

sender - (undocumented)

Returns:

(undocumented)

update

public ConfirmablePersistentImpl 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)

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)