+per #3927 Enable EventsourcedProcessor to handle ConfirmablePersistent

(cherry picked from commit 6db2a2838a142798a97889486712bfd0f9f5052e)
This commit is contained in:
Björn Antonsson 2014-03-24 11:21:21 +01:00 committed by Patrik Nordwall
parent d51e06b389
commit 6dfe51d71a
2 changed files with 24 additions and 4 deletions

View file

@ -71,6 +71,8 @@ private[persistence] trait Eventsourced extends Processor {
override def toString: String = "persisting events"
def aroundReceive(receive: Receive, message: Any) = message match {
case c: ConfirmablePersistent
processorStash.stash()
case PersistentBatch(b)
b.foreach(p deleteMessage(p.sequenceNr, true))
throw new UnsupportedOperationException("Persistent command batches not supported")