From 9cafeda344649f7cf033946eea9b174126a419ac Mon Sep 17 00:00:00 2001 From: Christopher Batey Date: Thu, 23 Aug 2018 09:13:53 +0100 Subject: [PATCH] Add inclusive to deletion api docs (#25390) --- .../src/main/scala/akka/persistence/Eventsourced.scala | 2 +- .../scala/akka/persistence/journal/AsyncWriteJournal.scala | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala b/akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala index 9b1ac8d859..27a3ee7890 100644 --- a/akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala +++ b/akka-persistence/src/main/scala/akka/persistence/Eventsourced.scala @@ -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` * 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 = { if (toSequenceNr == Long.MaxValue || toSequenceNr <= lastSequenceNr) diff --git a/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala b/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala index 3d78855f0f..02cc8ebcaa 100644 --- a/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala +++ b/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala @@ -160,11 +160,11 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery { case d @ DeleteMessagesTo(persistenceId, toSequenceNr, persistentActor) ⇒ breaker.withCircuitBreaker(asyncDeleteMessagesTo(persistenceId, toSequenceNr)) map { - case _ ⇒ DeleteMessagesSuccess(toSequenceNr) + _ ⇒ DeleteMessagesSuccess(toSequenceNr) } recover { case e ⇒ DeleteMessagesFailure(e, toSequenceNr) } pipeTo persistentActor onComplete { - case _ ⇒ if (publish) context.system.eventStream.publish(d) + _ ⇒ if (publish) context.system.eventStream.publish(d) } } }