Making sure that akka-remote and akka-remote-tests compiles and that tests are green

akka-remote-tests/src/main/scala/akka/remote/testconductor/Conductor.scala

@@ -86,6 +86,7 @@ trait Conductor { this: TestConductorExt ⇒
     if (_controller ne null) throw new RuntimeException("TestConductorServer was already started")
     _controller = system.actorOf(Props(new Controller(participants, controllerPort)), "controller")
     import Settings.BarrierTimeout
+    import system.dispatcher
     controller ? GetSockAddr flatMap { case sockAddr: InetSocketAddress ⇒ startClient(name, sockAddr) map (_ ⇒ sockAddr) }
   }
 

akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala

@@ -212,10 +212,12 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress)
           stay using d.copy(runningOp = None)
         case t: ThrottleMsg ⇒
           import settings.QueryTimeout
+          import context.dispatcher // FIXME is this the right EC for the future below?
           TestConductor().failureInjector ? t map (_ ⇒ ToServer(Done)) pipeTo self
           stay
         case d: DisconnectMsg ⇒
           import settings.QueryTimeout
+          import context.dispatcher // FIXME is this the right EC for the future below?
           TestConductor().failureInjector ? d map (_ ⇒ ToServer(Done)) pipeTo self
           stay
         case TerminateMsg(exit) ⇒

akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala

@@ -91,7 +91,7 @@ private[akka] class RemoteActorRefProvider(
 
     system.eventStream.subscribe(remoteClientLifeCycleHandler, classOf[RemoteLifeCycleEvent])
 
-    terminationFuture.onComplete(_ ⇒ transport.shutdown())
+    system.registerOnTermination(transport.shutdown())
   }
 
   def actorOf(system: ActorSystemImpl, props: Props, supervisor: InternalActorRef, path: ActorPath,

akka-remote/src/test/scala/akka/remote/NetworkFailureSpec.scala

@@ -10,15 +10,17 @@ import akka.remote.netty.NettyRemoteTransport
 import akka.actor.Actor
 import akka.testkit.AkkaSpec
 import akka.testkit.DefaultTimeout
-import scala.concurrent.Future
 
 import java.util.concurrent.{ TimeUnit, CountDownLatch }
 import java.util.concurrent.atomic.AtomicBoolean
+import scala.concurrent.{ ExecutionContext, Future }
 
 trait NetworkFailureSpec extends DefaultTimeout { self: AkkaSpec ⇒
   import Actor._
   import scala.concurrent.util.Duration
 
+  import system.dispatcher
+
   val BytesPerSecond = "60KByte/s"
   val DelayMillis = "350ms"
   val PortRange = "1024-65535"

akka-remote/src/test/scala/akka/remote/RemoteCommunicationSpec.scala

@@ -132,6 +132,7 @@ akka {
     }
 
     "not fail ask across node boundaries" in {
+      import system.dispatcher
       val f = for (_ ← 1 to 1000) yield here ? "ping" mapTo manifest[(String, ActorRef)]
       Await.result(Future.sequence(f), remaining).map(_._1).toSet must be(Set("pong"))
     }

akka-remote/src/test/scala/akka/remote/Ticket1978CommunicationSpec.scala

@@ -141,6 +141,7 @@ abstract class Ticket1978CommunicationSpec(val cipherConfig: CipherConfig) exten
       }
 
       "support ask" in {
+        import system.dispatcher
         val here = system.actorFor(otherAddress.toString + "/user/echo")
 
         val f = for (i ← 1 to 1000) yield here ? (("ping", i)) mapTo manifest[((String, Int), ActorRef)]