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

Add inclusive to deletion api docs (#25390)

Browse source
This commit is contained in:
Christopher Batey 2018-08-23 09:13:53 +01:00 • committed by GitHub
parent 001a7569b9
commit 9cafeda344
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala
View file

@ -432,7 +432,7 @@ private[persistence] trait Eventsourced extends Snapshotter with PersistenceStas
* messages may be deleted without specifying the actual sequence number by using `Long.MaxValue` * messages may be deleted without specifying the actual sequence number by using `Long.MaxValue`
* as the `toSequenceNr`. * as the `toSequenceNr`.
* *
* @param toSequenceNr upper sequence number bound of persistent messages to be deleted. * @param toSequenceNr upper sequence number (inclusive) bound of persistent messages to be deleted.
*/ */
def deleteMessages(toSequenceNr: Long): Unit = { def deleteMessages(toSequenceNr: Long): Unit = {
if (toSequenceNr == Long.MaxValue || toSequenceNr <= lastSequenceNr) if (toSequenceNr == Long.MaxValue || toSequenceNr <= lastSequenceNr)

4
akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala
View file

@ -160,11 +160,11 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery {
case d @ DeleteMessagesTo(persistenceId, toSequenceNr, persistentActor) ⇒ case d @ DeleteMessagesTo(persistenceId, toSequenceNr, persistentActor) ⇒
breaker.withCircuitBreaker(asyncDeleteMessagesTo(persistenceId, toSequenceNr)) map { breaker.withCircuitBreaker(asyncDeleteMessagesTo(persistenceId, toSequenceNr)) map {
case _ ⇒ DeleteMessagesSuccess(toSequenceNr) _ ⇒ DeleteMessagesSuccess(toSequenceNr)
} recover { } recover {
case e ⇒ DeleteMessagesFailure(e, toSequenceNr) case e ⇒ DeleteMessagesFailure(e, toSequenceNr)
} pipeTo persistentActor onComplete { } pipeTo persistentActor onComplete {
case _ ⇒ if (publish) context.system.eventStream.publish(d) _ ⇒ if (publish) context.system.eventStream.publish(d)
} }
} }
} }