public static class AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot extends java.lang.Object implements Message, scala.Product, scala.Serializable
AtLeastOnceDelivery
state. Can be retrieved with
AtLeastOnceDeliveryLike.getDeliverySnapshot()
and saved with Snapshotter.saveSnapshot(java.lang.Object)
.
During recovery the snapshot received in SnapshotOffer
should be set
with AtLeastOnceDeliveryLike.setDeliverySnapshot(akka.persistence.AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot)
.Constructor and Description |
---|
AtLeastOnceDeliverySnapshot(long currentDeliveryId,
scala.collection.immutable.Seq<AtLeastOnceDelivery.UnconfirmedDelivery> unconfirmedDeliveries) |
Modifier and Type | Method and Description |
---|---|
long |
currentDeliveryId() |
java.util.List<AtLeastOnceDelivery.UnconfirmedDelivery> |
getUnconfirmedDeliveries()
Java API
|
scala.collection.immutable.Seq<AtLeastOnceDelivery.UnconfirmedDelivery> |
unconfirmedDeliveries() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public AtLeastOnceDeliverySnapshot(long currentDeliveryId, scala.collection.immutable.Seq<AtLeastOnceDelivery.UnconfirmedDelivery> unconfirmedDeliveries)
public long currentDeliveryId()
public scala.collection.immutable.Seq<AtLeastOnceDelivery.UnconfirmedDelivery> unconfirmedDeliveries()
public java.util.List<AtLeastOnceDelivery.UnconfirmedDelivery> getUnconfirmedDeliveries()