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)
         }
     }
   }