|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PersistentRepr
Plugin API: representation of a persistent message in the journal plugin API.
SyncWriteJournal
,
AsyncWriteJournal
,
AsyncRecovery
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.util.List<java.lang.String> |
getConfirms()
Java API, Plugin API: channel ids of delivery confirmations that are available for this message. |
java.lang.Object |
payload()
This persistent message's payload. |
PersistentRepr |
prepareWrite(ActorContext context)
INTERNAL API. |
PersistentRepr |
prepareWrite(ActorRef sender)
INTERNAL API. |
int |
redeliveries()
Number of redeliveries. |
ActorRef |
sender()
Sender of this message. |
PersistentRepr |
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 . |
Methods inherited from interface akka.persistence.PersistentId |
---|
persistenceId, processorId, sequenceNr |
Method Detail |
---|
java.lang.Object payload()
payload
in interface Resequenceable
boolean deleted()
true
if this message is marked as deleted.
int redeliveries()
Channel
or PersistentChannel
.
scala.collection.immutable.Seq<java.lang.String> confirms()
java.util.List<java.lang.String> getConfirms()
boolean confirmable()
true
only if this message has been delivered by a channel.
Delivered confirmMessage()
ActorRef confirmTarget()
ActorRef sender()
sender
in interface Resequenceable
PersistentRepr prepareWrite(ActorRef sender)
sender
- (undocumented)
PersistentRepr prepareWrite(ActorContext context)
context
- (undocumented)
PersistentRepr 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
.
sequenceNr
- (undocumented)persistenceId
- (undocumented)deleted
- (undocumented)redeliveries
- (undocumented)confirms
- (undocumented)confirmMessage
- (undocumented)confirmTarget
- (undocumented)sender
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |