aboutsummaryrefslogtreecommitdiff
path: root/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
diff options
context:
space:
mode:
Diffstat (limited to 'flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala')
-rw-r--r--flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala b/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
index e616763..4b38c09 100644
--- a/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
+++ b/flow-samples/rwc/src/main/scala/com/github/jodersky/flow/example/SerialHandler.scala
@@ -17,12 +17,12 @@ class SerialHandler(port: String, baud: Int) extends Actor with ActorLogging {
def receive = {
- case OpenFailed(_, reason) => {
+ case OpenFailed(reason, _, _, _, _, _) => {
log.error(s"Connection failed, stopping handler. Reason: ${reason}")
context stop self
}
- case Opened(port) => {
+ case Opened(port, _, _, _, _) => {
log.info(s"Port ${port} is now open.")
context become opened(sender)
}