raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #29539 from akka/wip-27786-setDeliverySnapshot-patriknw

Browse source 
Fix time in AtLeastOnce.setDeliverySnapshot, #27786
This commit is contained in:
Patrik Nordwall 2020-09-07 15:15:47 +02:00 • committed by GitHub
commit 6becd8e0ee
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-persistence/src/main/scala/akka/persistence/AtLeastOnceDelivery.scala
View file

@ -361,7 +361,8 @@ trait AtLeastOnceDeliveryLike extends Eventsourced {
*/ */
def setDeliverySnapshot(snapshot: AtLeastOnceDeliverySnapshot): Unit = { def setDeliverySnapshot(snapshot: AtLeastOnceDeliverySnapshot): Unit = {
deliverySequenceNr = snapshot.currentDeliveryId deliverySequenceNr = snapshot.currentDeliveryId
val now = System.nanoTime() // deliver on next tick
val now = System.nanoTime() - redeliverInterval.toNanos
unconfirmed = scala.collection.immutable.SortedMap.from(snapshot.unconfirmedDeliveries.iterator.map(d => unconfirmed = scala.collection.immutable.SortedMap.from(snapshot.unconfirmedDeliveries.iterator.map(d =>
d.deliveryId -> Delivery(d.destination, d.message, now, 0))) d.deliveryId -> Delivery(d.destination, d.message, now, 0)))
} }