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

=per #18303 avoid causing match error in AsyncWriteJournal

Browse source
This commit is contained in:
Konrad Malawski 2015-08-24 14:58:37 +03:00
parent 3d4b5f57b0
commit e185718189
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -145,7 +145,7 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery {
}.recover {
case e ⇒ ReplayMessagesFailure(e)
}.pipeTo(replyTo).onSuccess {
case _ if publish ⇒ context.system.eventStream.publish(r)
case _ ⇒ if (publish) context.system.eventStream.publish(r)
}
case d @ DeleteMessagesTo(persistenceId, toSequenceNr, persistentActor) ⇒
@ -154,7 +154,7 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery {
} recover {
case e ⇒ DeleteMessagesFailure(e, toSequenceNr)
} pipeTo persistentActor onComplete {
case _ if publish ⇒ context.system.eventStream.publish(d)
case _ ⇒ if (publish) context.system.eventStream.publish(d)
}
}