akka.persistence
Class ConfirmablePersistent
java.lang.Object
akka.persistence.Persistent
akka.persistence.ConfirmablePersistent
- All Implemented Interfaces:
- Resequenceable
- Direct Known Subclasses:
- ConfirmablePersistentImpl
public abstract class ConfirmablePersistent
- extends Persistent
Persistent message that has been delivered by a Channel
or PersistentChannel
. Channel
destinations that receive messages of this type can confirm their receipt by calling confirm
.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConfirmablePersistent
public ConfirmablePersistent()
unapply
public static scala.Option<scala.Tuple3<java.lang.Object,java.lang.Object,java.lang.Object>> unapply(ConfirmablePersistent persistent)
ConfirmablePersistent
extractor.
- Parameters:
persistent
- (undocumented)
- Returns:
- (undocumented)
confirm
public abstract void confirm()
- Called by
Channel
and PersistentChannel
destinations to confirm the receipt of a
persistent message.
redeliveries
public abstract int redeliveries()
- Number of redeliveries. Only greater than zero if message has been redelivered by a
Channel
or PersistentChannel
.
- Returns:
- (undocumented)