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

=per #3844 Views now enforce autoUpdateReplayMax

Browse source
This commit is contained in:
Martin Krasser 2014-01-23 10:43:02 +01:00
parent 48f3804270
commit b667e8ff3a
5 changed files with 46 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -42,7 +42,7 @@ trait AsyncWriteJournal extends Actor with AsyncRecovery {
resequence(WriteMessageFailure(_, e))
}
resequencerCounter += persistentBatch.length + 1
case ReplayMessages(fromSequenceNr, toSequenceNr, max, processorId, processor, replayDeleted) ⇒
case r @ ReplayMessages(fromSequenceNr, toSequenceNr, max, processorId, processor, replayDeleted) ⇒
// Send replayed messages and replay result to processor directly. No need
// to resequence replayed messages relative to written and looped messages.
asyncReplayMessages(processorId, fromSequenceNr, toSequenceNr, max) { p ⇒
@ -51,7 +51,9 @@ trait AsyncWriteJournal extends Actor with AsyncRecovery {
case _ ⇒ ReplayMessagesSuccess
} recover {
case e ⇒ ReplayMessagesFailure(e)
} pipeTo (processor)
} pipeTo (processor) onSuccess {
case _ if publish ⇒ context.system.eventStream.publish(r)
}
case ReadHighestSequenceNr(fromSequenceNr, processorId, processor) ⇒
// Send read highest sequence number to processor directly. No need
// to resequence the result relative to written and looped messages.