diff --git a/akka-remote/src/main/scala/akka/remote/netty/Server.scala b/akka-remote/src/main/scala/akka/remote/netty/Server.scala index 3de1556bb3..7e4d1eaaa9 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/Server.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/Server.scala @@ -129,10 +129,6 @@ class RemoteServerAuthenticationHandler(secureCookie: Option[String]) extends Si } } -object ChannelLocalSystem extends ChannelLocal[ActorSystemImpl] { - override def initialValue(ch: Channel): ActorSystemImpl = null -} - @ChannelHandler.Sharable class RemoteServerHandler( val openChannels: ChannelGroup, diff --git a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala index b9c60e1f9c..6d92f98fb7 100644 --- a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala +++ b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala @@ -7,8 +7,11 @@ import org.scalatest.matchers.MustMatchers import akka.testkit.{ TestProbe, DefaultTimeout, AkkaSpec } import akka.util.duration._ import akka.actor.{ Cancellable, Actor, Props, ActorRef } +import akka.util.Timeout -class ConcurrentSocketActorSpec extends AkkaSpec with DefaultTimeout { +class ConcurrentSocketActorSpec extends AkkaSpec { + + implicit val timeout: Timeout = Timeout(15 seconds) def checkZeroMQInstallation = try {