akka.persistence
Class ConfirmablePersistentImpl

java.lang.Object
  extended by akka.persistence.Persistent
      extended by akka.persistence.ConfirmablePersistent
          extended by 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)