|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.Persistent akka.persistence.ConfirmablePersistent akka.persistence.ConfirmablePersistentImpl
public class ConfirmablePersistentImpl
INTERNAL API.
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 |
---|
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 |
---|
public static ConfirmablePersistentImpl apply(PersistentRepr persistent, Delivered confirmMessage, ActorRef confirmTarget)
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 int redeliveries()
ConfirmablePersistent
Channel
or PersistentChannel
.
redeliveries
in interface PersistentRepr
redeliveries
in class ConfirmablePersistent
public scala.collection.immutable.Seq<java.lang.String> confirms()
PersistentRepr
confirms
in interface PersistentRepr
public Delivered confirmMessage()
PersistentRepr
confirmMessage
in interface PersistentRepr
public ActorRef confirmTarget()
PersistentRepr
confirmTarget
in interface PersistentRepr
public ActorRef sender()
PersistentRepr
sender
in interface PersistentRepr
sender
in interface Resequenceable
public ConfirmablePersistent withPayload(java.lang.Object payload)
Persistent
payload
.
withPayload
in class Persistent
payload
- (undocumented)
public void confirm()
ConfirmablePersistent
Channel
and PersistentChannel
destinations to confirm the receipt of a
persistent message.
confirm
in class ConfirmablePersistent
public boolean confirmable()
PersistentRepr
true
only if this message has been delivered by a channel.
confirmable
in interface PersistentRepr
public ConfirmablePersistentImpl prepareWrite(ActorRef sender)
PersistentRepr
prepareWrite
in interface PersistentRepr
sender
- (undocumented)
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)
PersistentRepr
PersistentRepr
.
update
in interface PersistentRepr
sequenceNr
- (undocumented)persistenceId
- (undocumented)deleted
- (undocumented)redeliveries
- (undocumented)confirms
- (undocumented)confirmMessage
- (undocumented)confirmTarget
- (undocumented)sender
- (undocumented)
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 |