diff options
| -rw-r--r-- | flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala b/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala index 686cdb3..d163b0a 100644 --- a/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala +++ b/flow-main/src/main/scala/com/github/jodersky/flow/SerialManager.scala @@ -1,7 +1,7 @@ package com.github.jodersky.flow import akka.actor.{ Actor, ActorLogging, OneForOneStrategy } -import akka.actor.SupervisorStrategy.Stop +import akka.actor.SupervisorStrategy.{ Escalate, Stop } import internal.{ SerialConnection, Watcher } import scala.util.{ Failure, Success, Try } @@ -15,6 +15,7 @@ class SerialManager extends Actor with ActorLogging { import context._ override val supervisorStrategy = OneForOneStrategy() { + case _: Exception if sender == watcher => Escalate case _: Exception => Stop } |