object pool for InboundEnvelope

2016-06-06 08:26:15 +02:00 · 2016-06-06 08:26:15 +02:00 · 64a61d5a4c
commit 64a61d5a4c
parent 2e0986254c
13 changed files with 182 additions and 73 deletions
--- a/akka-remote/src/main/scala/akka/remote/artery/Control.scala
+++ b/akka-remote/src/main/scala/akka/remote/artery/Control.scala
@ -105,7 +105,7 @@ private[akka] class InboundControlJunction
      // InHandler
      override def onPush(): Unit = {
        grab(in) match {
-          case env @ InboundEnvelope(_, _, _: ControlMessage, _, _) ⇒
+          case env: InboundEnvelope if env.message.isInstanceOf[ControlMessage] ⇒
            observers.foreach(_.notify(env))
            pull(in)
          case env ⇒